public final class BusPublisher<T> extends Object implements org.reactivestreams.Publisher<T>
Selector
topic from the Bus
.
This stream will never emit a Subscriber.onComplete()
.
Create such stream with the provided factory, E.g.:
Streams.create(eventBus.on($("topic"))).consume(System.out::println)
Constructor and Description |
---|
BusPublisher(Bus<T> observable,
Selector selector) |
Modifier and Type | Method and Description |
---|---|
void |
subscribe(org.reactivestreams.Subscriber<? super T> s) |
String |
toString() |
Copyright © 2017. All rights reserved.