net.fortytwo.flow
Interface Source<T>

Type Parameters:

T - the type of data being passed

All Known Implementing Classes:

Buffer, Collector

public interface Source<T>

A push-based data source which passes data to a downstream sink

Author:

Joshua Shinavier (http://fortytwo.net)

Method Summary

void	writeTo(Sink<T> sink) Pushes this source's data into a given sink

Method Detail

writeTo

void writeTo(Sink<T> sink)
             throws RippleException

Pushes this source's data into a given sink

Parameters:

sink - the downstream sink to receive the data in this source

Throws:

RippleException - if a data handling error occurs