These are chat archives for akkadotnet/AkkaStreams

27th
May 2016
Chris Constantin
@cconstantin
May 27 2016 04:04
@Silv3rcircl3 @Horusiath I finally got around to work on the removal of the untyped interfaces from Reactive.Streams
akkadotnet/akka.net#1984
Chris Constantin
@cconstantin
May 27 2016 04:28
I am a bit ambivalent about the IUntypedSubscriber name. ISubscriber would have worked as well, but I wanted to put some distance to the ReactiveStreams interface.
I haven’t yet pushed the changes to Reactive.Streams, waiting to see if you’re OK with these changes
Marc Piechura
@marcpiechura
May 27 2016 05:31
@cconstantin Build is broken
Chris Constantin
@cconstantin
May 27 2016 06:17
@Silv3rcircl3 yes, the Reactive.Streams nuget package is not yet published
if you are OK with the code, I’ll publish
Marc Piechura
@marcpiechura
May 27 2016 06:18
Ah I see
Chris Constantin
@cconstantin
May 27 2016 15:53
@Silv3rcircl3 build passed, Reactive.Streams package published.
I think this is good to go
Marc Piechura
@marcpiechura
May 27 2016 16:01
@cconstantin Why uses the BoundarySubscriber FromTyped and the BoundaryPublisher is cast directly?
That confused me on my second remark
Chris Constantin
@cconstantin
May 27 2016 16:03
IActorPublishers are passed around in untyped messages in ActorGraphInterpreter, so it implements IUntypedPublisher
BoundaryPublisher is an ActorPublisher
BoundarySubscriber on the other hand implements ISubscriber<>
asymmetric, I know, but no other way to deal with imo
Marc Piechura
@marcpiechura
May 27 2016 16:05
Ah ok I see
Merged ;)
Chris Constantin
@cconstantin
May 27 2016 16:06
great, thanks
so now we’re good to merge into dev?
:)
Marc Piechura
@marcpiechura
May 27 2016 16:07
I would say yes :)
Chris Constantin
@cconstantin
May 27 2016 16:07
actually, I recall @Horusiath having some trouble with the postgres plugin?
@Horusiath can we go ahead and merge to dev? it would be great to have nuget nightlies available for streams and persistence query :)
Marc Piechura
@marcpiechura
May 27 2016 16:11
:shipit:
;)