Class StreamWriteFilter
java.lang.Object
org.apache.mina.core.filterchain.IoFilterAdapter
org.apache.mina.filter.stream.AbstractStreamWriteFilter<InputStream>
org.apache.mina.filter.stream.StreamWriteFilter
- All Implemented Interfaces:
IoFilter
Filter implementation which makes it possible to write
InputStream
objects directly using IoSession.write(Object). When an
InputStream is written to a session this filter will read the bytes
from the stream into IoBuffer objects and write those buffers
to the next filter. When end of stream has been reached this filter will
call IoFilter.NextFilter.messageSent(org.apache.mina.core.session.IoSession, org.apache.mina.core.write.WriteRequest) using the original
InputStream written to the session and notifies
WriteFuture on the
original WriteRequest.
This filter will ignore written messages which aren't InputStream
instances. Such messages will be passed to the next filter directly.
NOTE: this filter does not close the stream after all data from stream
has been written. The IoHandler should take
care of that in its
IoHandler.messageSent(IoSession,Object)
callback.
-
Nested Class Summary
Nested classes/interfaces inherited from interface IoFilter
IoFilter.NextFilter -
Field Summary
Fields inherited from class AbstractStreamWriteFilter
CURRENT_STREAM, CURRENT_WRITE_REQUEST, DEFAULT_STREAM_BUFFER_SIZE, WRITE_REQUEST_QUEUE -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class AbstractStreamWriteFilter
filterWrite, getWriteBufferSize, messageSent, onPreAdd, setWriteBufferSizeMethods inherited from class IoFilterAdapter
destroy, event, exceptionCaught, filterClose, init, inputClosed, messageReceived, onPostAdd, onPostRemove, onPreRemove, sessionClosed, sessionCreated, sessionIdle, sessionOpened, toString
-
Constructor Details
-
StreamWriteFilter
public StreamWriteFilter()
-
-
Method Details
-
getNextBuffer
- Specified by:
getNextBufferin classAbstractStreamWriteFilter<InputStream>- Throws:
IOException
-
getMessageClass
- Specified by:
getMessageClassin classAbstractStreamWriteFilter<InputStream>
-