hu.akarnokd.reactive4java.reactive

Class Invoke

java.lang.Object

hu.akarnokd.reactive4java.reactive.Invoke

public final class Invoke
extends java.lang.Object

Helper class for invoking actions during an stream of observable sequence.

Note: Rx calls these as Do.

Since:

0.97

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Invoke.OnNext<T> Executes an action on the received element in the next() call while relaying events.
static class	Invoke.OnNextError<T> Invokes an action on the next and error methods while relaying events.
static class	Invoke.OnNextErrorFinish<T> Invoke an action on the next, error and finish methods while relaying events.
static class	Invoke.OnNextFinish<T> Invoke an action on the next and finish methods while relaying events.
static class	Invoke.OnObserver<T> Invoke the methods of the given observer while relaying events.

Method Summary

Methods inherited from class java.lang.Object

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