Skip to content

Remove Multicast #1779

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
benjchristensen opened this issue Oct 20, 2014 · 3 comments
Closed

Remove Multicast #1779

benjchristensen opened this issue Oct 20, 2014 · 3 comments
Milestone

Comments

@benjchristensen
Copy link
Member

While discussing #1732 with @headinthebox we determined that multicast is troublesome and an "implementation detail" that leaked into the public API.

The publish(), replay(), share(), cache() operators are what should actually be used.

If multicast behavior is truly still wanted with "hot" semantics (and no backpressure) it can be achieved by doing this:

Observable<T> xs = ...;
Subject<T, T> s = SubjectImpl.create();
s.subscribe(observerA);
s.subscribe(observerB);
xs.subscribe(s);

We will remove multicast in 1.0 so as to eliminate it as a stumbling block and allow for correct backpressure propagation (which doesn't work with subjects).

@benjchristensen
Copy link
Member Author

Done in #1786

@yogurtearl
Copy link

Was using this... :/

@benjchristensen
Copy link
Member Author

Does your use case not get covered by publish(), replay(), share() or cache()?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants