public final class Take
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
Take.First<T>
Creates an observable which takes the specified number of
Ts from the source, unregisters and completes.
|
static class |
Take.FirstTimed<T>
Takes the elements from the source sequence
until the time runs out.
|
static class |
Take.Last<T>
Returns an observable which returns the last
count
elements from the source observable. |
static class |
Take.LastBuffer<T>
Returns an observable which returns the last
count
elements from the source observable and
returns it as a single list. |
static class |
Take.LastBufferTimed<T>
Returns elements from the end of the sequence during the specified
time interval in one list.
|
static class |
Take.LastScheduled<T>
Returns an observable which returns the last
count
elements from the source observable and emits them from
the specified scheduler pool. |
static class |
Take.LastTimed<T>
Returns elements from the end of the sequence during the specified
time interval.
|
static class |
Take.Until<T,U>
Creates an observable which takes values from the source until
the signaller produces a value.
|
static class |
Take.While<T>
Creates an observable which takes values from source until
the predicate returns false for the current element, then skips the remaining values.
|
static class |
Take.WhileIndexed<T>
Creates an observable which takes values from source until
the indexed predicate returns false for the current element, then skips the remaining values.
|
static class |
Take.WhileLongIndexed<T>
Creates an observable which takes values from source until
the indexed predicate returns false for the current element, then skips the remaining values.
|