Modifier and Type | Method and Description |
---|---|
static <T> ReplayRelay<T> |
ReplayRelay.create()
Creates an unbounded replay relay.
|
static <T> ReplayRelay<T> |
ReplayRelay.create(int capacityHint)
Creates an unbounded replay relay with the specified initial buffer capacity.
|
static <T> ReplayRelay<T> |
ReplayRelay.createWithSize(int maxSize)
Creates a size-bounded replay relay.
|
static <T> ReplayRelay<T> |
ReplayRelay.createWithTime(long maxAge,
TimeUnit unit,
io.reactivex.Scheduler scheduler)
Creates a time-bounded replay relay.
|
static <T> ReplayRelay<T> |
ReplayRelay.createWithTimeAndSize(long maxAge,
TimeUnit unit,
io.reactivex.Scheduler scheduler,
int maxSize)
Creates a time- and size-bounded replay subject.
|
Copyright © 2015-2016. All Rights Reserved.