fehmicansaglam/tepkin

Reactive MongoDB Driver for Scala and Java 8

Fehmi Can Sağlam

@fehmicansaglam

Adding a sink method to MongoCollection which returns a Sink makes sense.

I am not sure that we need an ActorSubscriber. Let me try to come up with a poc.

Daniel Wegener

@danielwegener

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

Fehmi Can Sağlam

@fehmicansaglam

Sure

Fehmi Can Sağlam

@fehmicansaglam

After reading the docs I agree that we need an ActorSubscriber in order to support back pressure

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

Fehmi Can Sağlam

@fehmicansaglam

@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

Mike Limansky

@limansky

Hi everyone. Could anybody tell me how to pronounce "Tepkin" properly? :-)

Fehmi Can Sağlam

@fehmicansaglam

It means reactive in Turkish

It is read as it is written, if it means anything to you:)

Mike Limansky

@limansky

And where should I put the stress?

I'm asking, because I'm going to mention it in my speech at Scaladays.

Fehmi Can Sağlam

@fehmicansaglam

Cool:) actually google translate application pronounces it correctly. It has 2 syllables. Tep-kin. Does it help?

And could share the name of your presentation?

Mike Limansky

@limansky

yep, it helps. thanks

sure, http://event.scaladays.org/scaladays-amsterdam-2015#!#schedulePopupExtras-6917

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.

Fehmi Can Sağlam

@fehmicansaglam

Will you mention about Tepkin in a good way or not?:)

Mike Limansky

@limansky

In the way that it not supported in mongoquery yet :-D

Fehmi Can Sağlam

@fehmicansaglam

Haha:)

Mike Limansky

@limansky

but I'm thinking on it :)

Fehmi Can Sağlam

@fehmicansaglam

Good news. Good luck for your presentation

Mike Limansky

@limansky

thanks

the problem is that I didn't find the way to construct BsonDocument in macro from the List[(String, Any)].

Fehmi Can Sağlam

@fehmicansaglam

Hmm

Fehmi Can Sağlam

@fehmicansaglam

I will come up with a working gist soon

Mike Limansky

@limansky

thanx

Fehmi Can Sağlam

@fehmicansaglam

@limansky i have updated 0.5-SNAPSHOT

    val elements: List[(String, Any)] = List("name" -> "name", "age" -> 3, "salary" -> 4.0)
    val document: BsonDocument = BsonDocument.from(elements)

you can construct a BsonDocument from (String, Any) tuples like above.

Mike Limansky

@limansky

@fehmicansaglam Great! Thanx. I'll try to use it this evening :+1:

Harmeet Singh(Taara)

@harmeetsingh0013

@fehmicansaglam is there discussion room for #reactivemongo-extensions ?

Fehmi Can Sağlam

@fehmicansaglam

Nope

Harmeet Singh(Taara)

@harmeetsingh0013

i have litte probem with query dsl

if you allow, i can paste the link of my query here ?

Fehmi Can Sağlam

@fehmicansaglam

Pleas file an issue on github

Or you can ask in the reactivemongo google group

This room is just for tepkin

Harmeet Singh(Taara)

@harmeetsingh0013

ok @fehmicansaglam , paste the issue on githum abd google group

that's why, i taken the permission from you

Fehmi Can Sağlam

@fehmicansaglam

ok, i have posted the answer to SO.

Fehmi Can Sağlam

@fehmicansaglam

If anyone is interested I have opened a room for my new project: elastic-streams https://gitter.im/fehmicansaglam/elastic-streams

I am trying to come up with an implementation of reactive streams for elasticsearch

Daniel Wegener

@danielwegener

hey @fehmicansaglam . Sorry that it took so long to report back. The collection sink api looks just as expected. very nice, thank you. I had no luck yet running this in a combined example (like having a flow stdin->collection.sink ; collection.find(tailable=true) -> stdout) but I'll give you a link once its running. might be a nice example.

Where communities thrive

People

Repo info

Activity