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> UnicastProcessor<T> |
UnicastProcessor.create()
Creates an UnicastSubject with an internal buffer capacity hint 16.
|
static <T> UnicastProcessor<T> |
UnicastProcessor.create(boolean delayError)
Creates an UnicastProcessor with default internal buffer capacity hint and delay error flag.
|
static <T> UnicastProcessor<T> |
UnicastProcessor.create(int capacityHint)
Creates an UnicastProcessor with the given internal buffer capacity hint.
|
static <T> UnicastProcessor<T> |
UnicastProcessor.create(int capacityHint,
Runnable onCancelled)
Creates an UnicastProcessor with the given internal buffer capacity hint and a callback for
the case when the single Subscriber cancels its subscription.
|
static <T> UnicastProcessor<T> |
UnicastProcessor.create(int capacityHint,
Runnable onCancelled,
boolean delayError)
Creates an UnicastProcessor with the given internal buffer capacity hint, delay error flag and a callback for
the case when the single Subscriber cancels its subscription.
|
Copyright © 2019. All rights reserved.