Package | Description |
---|---|
reactor.core |
Core components of the framework supporting extensions to the Reactive Stream
programming model.
|
Modifier and Type | Method and Description |
---|---|
static Disposable.Composite |
Disposables.composite()
Create a new empty
Disposable.Composite with atomic guarantees on all mutative
operations. |
static Disposable.Composite |
Disposables.composite(Disposable... disposables)
Create and initialize a new
Disposable.Composite with atomic guarantees on
all mutative operations. |
static Disposable.Composite |
Disposables.composite(Iterable<? extends Disposable> disposables)
Create and initialize a new
Disposable.Composite with atomic guarantees on
all mutative operations. |