org.hobbit.core.rabbit

Interface IncomingStreamHandler

All Known Subinterfaces:

PairedStreamHandler

All Known Implementing Classes:

AbstractEvaluationModule, AbstractEvaluationStorage.ExpectedResponseReceiver, AbstractEvaluationStorage.SystemResponseReceiver, AbstractStreamingEvaluationModule, AbstractStreamingSystemAdapter.GeneratedDataHandler, AbstractStreamingSystemAdapter.GeneratedTaskHandler, AbstractStreamingTaskGenerator.GeneratedDataHandler

public interface IncomingStreamHandler

This interface defines a method for handling incoming streaming data.

Author:

Michael Röder (roeder@informatik.uni-leipzig.de)

Method Summary

Modifier and Type	Method and Description
void	handleIncomingStream(String streamId, InputStream stream) Method handling the given InputStream.

Method Detail

handleIncomingStream

void handleIncomingStream(String streamId,
                          InputStream stream)

Method handling the given InputStream. Note that it is assumed that the method blocks until the input stream is read. After the program leaves the method, the stream is closed.

Parameters:

streamId - the id of the stream

stream - the input stream containing the incoming data