Package | Description |
---|---|
io.reactivex.processors |
Classes extending the Flowable base reactive class and implementing
the Subscriber interface at the same time (aka hot Flowables).
|
Modifier and Type | Method and Description |
---|---|
static <T> MulticastProcessor<T> |
MulticastProcessor.create()
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and no refCount-behavior.
|
static <T> MulticastProcessor<T> |
MulticastProcessor.create(boolean refCount)
Constructs a fresh instance with the default Flowable.bufferSize() prefetch
amount and the optional refCount-behavior.
|
static <T> MulticastProcessor<T> |
MulticastProcessor.create(int bufferSize)
Constructs a fresh instance with the given prefetch amount and no refCount behavior.
|
static <T> MulticastProcessor<T> |
MulticastProcessor.create(int bufferSize,
boolean refCount)
Constructs a fresh instance with the given prefetch amount and the optional
refCount-behavior.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.