Package | Description |
---|---|
reactor.io.net.impl.zmq | |
reactor.rx.action.aggregation | |
reactor.rx.action.error | |
reactor.rx.broadcast |
Broadcasters are akin to Reactive Extensions Subject.
|
Constructor and Description |
---|
ZeroMQWorker(UUID id,
int socketType,
int ioThreadCount,
org.zeromq.ZContext zmq,
Broadcaster<org.zeromq.ZMsg> b) |
Modifier and Type | Method and Description |
---|---|
protected Broadcaster<T> |
WindowShiftWhenAction.createWindowStream(T first) |
Broadcaster<T> |
WindowWhenAction.currentWindow() |
Modifier and Type | Method and Description |
---|---|
Broadcaster<Throwable> |
RetryWhenAction.retryStream() |
Modifier and Type | Class and Description |
---|---|
class |
BehaviorBroadcaster<O>
A
Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline. |
class |
SerializedBroadcaster<O>
A
Broadcaster is a subclass of Stream which exposes methods for publishing values into the pipeline. |
Modifier and Type | Method and Description |
---|---|
Broadcaster<O> |
Broadcaster.capacity(long elements) |
static <T> Broadcaster<T> |
Broadcaster.create()
Build a Broadcaster, ready to broadcast values with
.Broadcaster#onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
SerializedBroadcaster.create()
Build a Broadcaster, ready to broadcast values with
.Broadcaster#onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
Broadcaster.create(Dispatcher dispatcher)
Build a Broadcaster, ready to broadcast values with
Action.onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.create(Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then ready to broadcast values with
Action.onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
Broadcaster.create(Environment env)
Build a Broadcaster, ready to broadcast values with
onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.create(Environment env)
Build a Broadcaster, first broadcasting the most recent signal then ready to broadcast values with
onNext(Object) ,
onError(Throwable) , () . |
static <T> Broadcaster<T> |
SerializedBroadcaster.create(Environment env)
Build a Broadcaster, ready to broadcast values, ready to broadcast values with
onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
Broadcaster.create(Environment env,
Dispatcher dispatcher)
|
static <T> Broadcaster<T> |
BehaviorBroadcaster.create(Environment env,
Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then
ready to broadcast values with
(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value)
Build a Broadcaster, rfirst broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
.Broadcaster#onNext(Object) ,
onError(Throwable) , () . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value,
Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
Action.onNext(Object) ,
onError(Throwable) , onComplete() . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value,
Environment env)
Build a Broadcaster, first broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
onNext(Object) ,
onError(Throwable) , () . |
static <T> Broadcaster<T> |
BehaviorBroadcaster.first(T value,
Environment env,
Dispatcher dispatcher)
Build a Broadcaster, first broadcasting the most recent signal then starting with the passed value,
then ready to broadcast values with
(Object) ,
onError(Throwable) , onComplete() . |
Copyright © 2017. All rights reserved.