Package ClusterShell :: Package Worker :: Module Worker :: Class StreamClient

Class StreamClient

StreamWorker's default EngineClient.

StreamClient is the EngineClient subclass used by default by StreamWorker. It handles some generic methods to pass data to the StreamWorker.

Instance Methods

_start(self)
Called on EngineClient start.

source code

_read(self, sname, size=65536)
Read data from process.

source code

_close(self, abort, timeout)
Close client.

source code

_handle_read(self, sname)
Engine is telling us there is data available for reading.

source code

_flush_read(self, sname)
Called at close time to flush stream read buffer.

source code

write(self, buf, sname=None)
Write to writable stream(s).

source code

set_write_eof(self, sname=None)
Set EOF flag to writable stream(s).

source code

Method Details

Called on EngineClient start.

Read data from process.

Close client. See EngineClient._close().

Engine is telling us there is data available for reading.

Called at close time to flush stream read buffer.