Commit f87879d

authored

2.x: Add MulticastProcessor (#6002)

* 2.x: Add MulticastProcessor * Improve coverage, fix NPE before upstream arrives * Address review feedback.

1 parent 5ce21f4 commit f87879dCopy full SHA for f87879d

2 files changed

+1429

-0

lines changed

src
- main/java/io/reactivex/processors
  - MulticastProcessor.java
- test/java/io/reactivex/processors
  - MulticastProcessorTest.java

+1429

-0

lines changed

Comments

(0)