|
Class Summary |
| AdapterSink<T,E extends Exception,F extends Exception> |
User: josh
Date: Mar 26, 2010
Time: 6:58:12 PM |
| AddToCollectionSink<T,E extends Exception> |
Author: josh
Date: Mar 11, 2008
Time: 8:45:29 AM |
| Buffer<T,E extends Exception> |
|
| Collector<T,E extends Exception> |
Note: while this class is not actually thread-safe, put() may safely be
called while writeTo() is in progress. |
| DistinctFilter<T,E extends Exception> |
|
| HistorySink<T,E extends Exception> |
A Sink which maintains a history of items received during any given interval between calls to
its advance method. |
| NullMapping<D,R,E extends Exception> |
Author: josh
Date: Apr 2, 2008
Time: 3:43:54 PM |
| NullSink<T,E extends Exception> |
|
| NullSource<T,E extends Exception> |
|
| Pointer<T> |
|
| SimpleReadOnlyCollection<T> |
Author: josh
Date: Mar 25, 2009
Time: 8:52:02 PM |
| Switch<T,E extends Exception> |
|
| SynchronizedSink<T,E extends Exception> |
|
| Tee<T,E extends Exception> |
|