hu.akarnokd.reactive4java.reactive

Class Take

java.lang.Object

hu.akarnokd.reactive4java.reactive.Take

public final class Take
extends java.lang.Object

Helper class for take like operators.

Since:

0.97

Nested Class Summary

Nested Classes

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.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait