fehmicansaglam/tepkin#13
just go ahead with reactivemongo if you are starting a project right now.
but he problm is that, when this query "userService.findRandom($and("email" $eq clientCredential.clientId, "password" $eq clientCredential.clientSecret, "grantType" $eq grantType))" the values return empty
but when i run this query "userService.findRandom(BSONDocument("email" -> clientCredential.clientId, "password" -> clientCredential.clientSecret, "grantType" -> grantType));" the values are return, what is the problem with query DSL ?
If you use $doc instead of $and both queries will be identical
@harmeetsingh0013 can you try that?
Can you create a sample app and file an issue on reactivemongo-extensions project?
And please do remember that this group is just for talking about tepkin.
Ah I've overlooked that one, cheers. Yeah thats going into the direction. Though It is a bit uncomfortable to fit this into normal akka-stream composition if you have to call insertFromSource on a Source rather than just provide a InsertSink that can be composed into any stream graph and be materialized by graph.run
Possible errournous write results could let the stream fail and bubble the error upstream
I think the stream documentation suggests to wrap it up as an ActorSubscriber (http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC2/scala/stream-integrations.html)
I am not sure that we need an ActorSubscriber. Let me try to come up with a poc.
The streams api takes a bit different approach as far is I understood. It would rather let you create a Sink that is not bound to a concrete external service but rather let you provide a function that resolves your external service when you materialize the Sink. Such an API like Mongo.insertSink( collection:()=> MongoCollection ) : Sink[DBObject]
Sounds great, let me know if I can help you in some way with that
But I am not sure about the api. Should a sink be reusable? MongoCollection.sinkM: Sink[List[BsonDocument, M] seems good to me.
```
def ignore: Sink[Any, Unit] =
new Sink(new BlackholeSink(DefaultAttributes.ignoreSink, shape("BlackholeSink")))
This code is from akka streams itself. It creates a new sink every time Sink.ignore is called. So it makes sense to create a new Sink for each MongoCollection.sink call
@danielwegener can you comment on SinkExample: https://github.com/fehmicansaglam/tepkin/blob/master/examples/src/main/scala/net/fehmicansaglam/tepkin/examples/SinkExample.scala
I have also updated the snapshot
It means reactive in Turkish
It is read as it is written, if it means anything to you:)
I'm asking, because I'm going to mention it in my speech at Scaladays.
And could share the name of your presentation?
so, I will say a little about existing solutions for MongoDB in Scala, and why I started to develop MongoQuery, before cover the implementation details.