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> ReplayProcessor<T> |
ReplayProcessor.create()
Creates an unbounded ReplayProcessor.
|
static <T> ReplayProcessor<T> |
ReplayProcessor.create(int capacityHint)
Creates an unbounded ReplayProcessor with the specified initial buffer capacity.
|
static <T> ReplayProcessor<T> |
ReplayProcessor.createWithSize(int maxSize)
Creates a size-bounded ReplayProcessor.
|
static <T> ReplayProcessor<T> |
ReplayProcessor.createWithTime(long maxAge,
TimeUnit unit,
Scheduler scheduler)
Creates a time-bounded ReplayProcessor.
|
static <T> ReplayProcessor<T> |
ReplayProcessor.createWithTimeAndSize(long maxAge,
TimeUnit unit,
Scheduler scheduler,
int maxSize)
Creates a time- and size-bounded ReplayProcessor.
|
Copyright © 2018 JBoss by Red Hat. All rights reserved.