Package com.github.davidmoten.rx.internal.operators

Interface Summary

Interface	Description
QueueWithSubscription<T>

Class Summary

Class	Description
FileBasedSPSCQueueMemoryMapped<T>
FileBasedSPSCQueueMemoryMappedReaderWriter<T>
NullSentinel
ObservableServerSocket
OnSubscribeCacheResetable<T>
OnSubscribeDoOnEmpty<T>
OnSubscribeFromQueue<T>
OnSubscribeInputStream
OnSubscribeMapLast<T>
OnSubscribeReader
OnSubscribeRepeating<T>
OperatorBufferPredicateBoundary<T>	Buffers values into a continuous, non-overlapping Lists where the boundary is determined by a predicate returning true.
OperatorBufferToFile<T>
OperatorDoOnNth<T>
OperatorFromTransformer<R,T>	Converts an Transformer (a function converting one Observable into another) into an Observable.Operator.
OperatorSampleFirst<T>	Throttle by windowing a stream and returning the first value in each window.
OperatorUnsubscribeEagerly<T>
OperatorWindowMinMax<T>	Uses a double-ended queue and collapses entries when they are redundant (whenever a value is added to the queue all values at the end of the queue that are greater or equal to that value are removed).
OrderedMerge<T>
Permutations
Permutations.Swap<T>
TransformerDecode
TransformerDelayFinalUnsubscribe<T>
TransformerLimitSubscribers<T>
TransformerOnBackpressureBufferRequestLimiting<T>
TransformerOnTerminateResume<T>	Switches to different Observables if the main source completes or signals an error.
TransformerStateMachine<State,In,Out>
TransformerStringSplit

Enum Summary

Enum	Description
OperatorWindowMinMax.Metric