Package org.jgrapes.io.util
Class InputStreamPipeline
java.lang.Object
org.jgrapes.io.util.InputStreamPipeline
- All Implemented Interfaces:
Runnable
Forwards the content of an input stream as a sequence of
Output
events.-
Constructor Summary
ConstructorsConstructorDescriptionInputStreamPipeline
(InputStream in, IOSubchannel channel) Creates a new pipeline that sends the data from the given input stream as events on the given channel, using the channel’s response pipeline.InputStreamPipeline
(InputStream in, IOSubchannel channel, EventPipeline eventPipeline) Creates a new pipeline that sends the data from the given input stream as events on the given channel, using the given event pipeline. -
Method Summary
Modifier and TypeMethodDescriptionvoid
run()
Suppresses the sending of a close event when the stream is closed.
-
Constructor Details
-
InputStreamPipeline
Creates a new pipeline that sends the data from the given input stream as events on the given channel, using the given event pipeline.- Parameters:
in
- the input stream to read fromchannel
- the channel to send toeventPipeline
- the event pipeline used for firing events
-
InputStreamPipeline
Creates a new pipeline that sends the data from the given input stream as events on the given channel, using the channel’s response pipeline.- Parameters:
in
- the input stream to read fromchannel
- the channel to send to
-
-
Method Details