org.mule.transport.tcp.integration

Class EOFStreamingTestComponent

java.lang.Object

org.mule.tck.functional.FunctionalStreamingTestComponent

org.mule.transport.tcp.integration.EOFStreamingTestComponent

All Implemented Interfaces:

Callable, EventListener

public class EOFStreamingTestComponent
extends FunctionalStreamingTestComponent

Extends the FunctionalStreamingTestComponent to wait for data in a non blocking fashion for the StreamingProtocol.

See Also:

EventCallback

Field Summary

Fields inherited from class org.mule.tck.functional.FunctionalStreamingTestComponent

logger, STREAM_BUFFER_SIZE, STREAM_SAMPLE_SIZE

Constructor Summary

Constructors

Constructor and Description
EOFStreamingTestComponent()

Method Summary

Methods

Modifier and Type	Method and Description
protected int	read(InputStream is, byte[] buffer)

Methods inherited from class org.mule.tck.functional.FunctionalStreamingTestComponent

getNumber, getSummary, onCall, setEventCallback, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

EOFStreamingTestComponent

public EOFStreamingTestComponent()

Method Detail

read

protected int read(InputStream is,
       byte[] buffer)
            throws IOException

Overrides:

read in class FunctionalStreamingTestComponent

Throws:

IOException