Skip to content

Add toSubscriber conversion #24

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
searler opened this issue Jan 10, 2015 · 1 comment
Closed

Add toSubscriber conversion #24

searler opened this issue Jan 10, 2015 · 1 comment

Comments

@searler
Copy link

searler commented Jan 10, 2015

The article uses internal implementation code from the 0.3 version, as follows:

 val sub = new Subscriber[String]() {
      ...
}
    val subSink = SubscriberSink(new RxSubscriberToRsSubscriberAdapter(sub));

This use case seems reasonable, at least in the context of integration with Akka Streams

That would require that toSubscriber methods be added to RxReactiveStreams

@ldaley
Copy link
Collaborator

ldaley commented Jan 11, 2015

We would add this as RxReactiveStreams.toSubscriber().

@ldaley ldaley closed this as completed in bcd1e46 Jan 12, 2015
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants