Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Nov 30 2018 19:29
    mfurkandemir starred fehmicansaglam/tepkin
  • Oct 20 2017 12:55
    Athedorer starred fehmicansaglam/tepkin
  • Mar 02 2017 09:27
    Travis jeroenr/tepkin@f0fe216 (upgradeakka) passed (39)
  • Mar 02 2017 09:25
    jeroenr closed #32
  • Mar 02 2017 09:25
    jeroenr opened #32
  • Aug 12 2016 01:09
    igorlimansky starred fehmicansaglam/tepkin
  • Jun 04 2016 07:49
    fehmicansaglam closed #31
  • Jun 04 2016 07:49
    fehmicansaglam commented #31
  • Jun 03 2016 03:48
    Whitilied opened #31
  • Apr 15 2016 01:22
    cm2316 starred fehmicansaglam/tepkin
  • Apr 05 2016 09:22
    Travis jeroenr/tepkin (propagateerrors) passed (36)
  • Mar 26 2016 19:00
    joecwu starred fehmicansaglam/tepkin
  • Mar 15 2016 12:25
    ginnun starred fehmicansaglam/tepkin
  • Mar 11 2016 21:18
    steveswing starred fehmicansaglam/tepkin
  • Mar 10 2016 08:29
    jeroenr commented #30
  • Mar 10 2016 07:12
    fehmicansaglam commented #30
  • Mar 08 2016 13:40
    Travis jeroenr/tepkin (v0.7) passed (32)
  • Mar 08 2016 13:27
    Travis jeroenr/tepkin@8c867d0 (fixorderby) passed (28)
  • Mar 08 2016 13:22
    jeroenr closed #30
  • Mar 08 2016 13:22
    jeroenr commented #30
Fehmi Can Sağlam
@fehmicansaglam
So you are talking about a new api or modifying the current insertFromSource api?
Daniel Wegener
@danielwegener
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
Daniel Wegener
@danielwegener
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)
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
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
:D
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
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