Package org.jgrapes.io.util

Class BufferedReaderPipeline

java.lang.Object

org.jgrapes.io.util.BufferedReaderPipeline

All Implemented Interfaces:

Runnable

public class BufferedReaderPipeline
extends Object
implements Runnable

Forwards the lines from a BufferedReader as a sequence of Output (or optionally Input) events.

Constructor Summary

Constructors

Constructor	Description
BufferedReaderPipeline(BufferedReader in, IOSubchannel channel)	Creates a new pipeline that sends the lines from the given reader as events on the given channel, using the channel’s response pipeline.
BufferedReaderPipeline(BufferedReader in, IOSubchannel channel, EventPipeline eventPipeline)	Creates a new pipeline that sends the lines from the given reader as events on the given channel, using the given event pipeline.

Method Summary

Modifier and Type	Method	Description
void	run()
BufferedReaderPipeline	sendInputEvents()	Causes the data to be fired as Input events rather than the usual Output events.
BufferedReaderPipeline	setEventAssociations(Map<Object,Object> associations)	Configure associations that are applied to the generated Output events, see Event.setAssociated(java.lang.Object, java.lang.Object).
BufferedReaderPipeline	suppressClosed()	Suppresses the sending of a closed event when the stream is closed.

Methods inherited from class java.lang.Object

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

Constructor Details

BufferedReaderPipeline

public BufferedReaderPipeline(BufferedReader in,
 IOSubchannel channel,
 EventPipeline eventPipeline)

Creates a new pipeline that sends the lines from the given reader as events on the given channel, using the given event pipeline.

Parameters:

in - the reader to read from

channel - the channel to send to

eventPipeline - the event pipeline used for firing events

BufferedReaderPipeline

public BufferedReaderPipeline(BufferedReader in,
 IOSubchannel channel)

Creates a new pipeline that sends the lines from the given reader as events on the given channel, using the channel’s response pipeline.

Parameters:

in - the reader to read from

channel - the channel to send to

Method Details

sendInputEvents

public BufferedReaderPipeline sendInputEvents()

Causes the data to be fired as Input events rather than the usual Output events.

Returns:

the stream for easy chaining

suppressClosed

public BufferedReaderPipeline suppressClosed()

Suppresses the sending of a closed event when the stream is closed.

Returns:

the stream for easy chaining

setEventAssociations

public BufferedReaderPipeline setEventAssociations(Map<Object,Object> associations)

Configure associations that are applied to the generated Output events, see Event.setAssociated(java.lang.Object, java.lang.Object).

Parameters:

associations - the associations to apply

Returns:

the pipeline for easy chaining

run

public void run()

Specified by:

run in interface Runnable