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

EOFStreamingTestComponent()

Method Summary

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