fehmicansaglam/tepkin

Reactive MongoDB Driver for Scala and Java 8

Fehmi Can Sağlam

@fehmicansaglam

```

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.

Daniel Wegener

@danielwegener

I am still wondering if one could make the collection.find() returning directly a Source instead of returning a Future[Source]. In the case when the future would fail, you could just let the stream itself fail directly. This could enable the use of stream supervision for recoverable failures (like when the mongo is not available during flow materialization, recover with a restart). In the end, Sources are easier to compose.

Fehmi Can Sağlam

@fehmicansaglam

@danielwegener I have changed Future[Source] return values to Source and updated 0.5-SNAPSHOT

I agree that it is easier to use the api right now

Daniel Wegener

@danielwegener

Again, cheers, @fehmicansaglam, that was awesome quick.

Daniel Wegener

@danielwegener

Mhm weird. Sink seems to work fine but the MongoCursor seem to receive a reply with a cursorId 0 (as of documentation that states that indicates a dead cursor, whatever that means) and thus eagerly closes the stream. Would you be fine if I'd add ResponseFlags to the reply class?

Fehmi Can Sağlam

@fehmicansaglam

@danielwegener as you said if no documents match the query(or the collection is empty) cursor is dead. If you add at least 1 document to the capped collection everything works fine. I couldn't find much in the documentation so I left it as it is.

What do you mean by ResponseFlags? Could you point me to the documentation?

Where communities thrive

People

Repo info

Activity