org.mule.extension.socket.internal

Class TcpInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.apache.commons.io.input.ProxyInputStream

org.mule.extension.socket.internal.TcpInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class TcpInputStream
extends org.apache.commons.io.input.ProxyInputStream

Used in TcpWorker as the input parameter for the read() method on the TcpProtocol interface. If you wish to simply use the InputStream as the message payload that you're reading in, you just call setStreaming(boolean) so that Mule knows to stop listening for more messages on that stream. Also, the if streaming is activated, the TcpWorker using this stream will wait until the streaming has been completely sent before closing the InputStream.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
TcpInputStream(InputStream inputStream)

Method Summary

Modifier and Type	Method and Description
boolean	isStreaming()
void	setStreaming(boolean streaming)

Methods inherited from class org.apache.commons.io.input.ProxyInputStream

afterRead, available, beforeRead, close, handleIOException, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpInputStream

public TcpInputStream(InputStream inputStream)

Method Detail

isStreaming

public boolean isStreaming()

setStreaming

public void setStreaming(boolean streaming)