twisted.spread.test.test_pb.IOPump

class documentation

class IOPump:

Constructor: IOPump(client, server, clientIO, serverIO)

View In Hierarchy

Utility to pump data between clients and servers for protocol testing.

Perhaps this is a utility worthy of being in protocol.py?

Method __init__ Undocumented
Method flush Pump until there is no more input or output or until stop is called. This does not run any timers, so don't use it with any code that calls reactor.callLater.
Method pump Move data back and forth.
Method stop Stop a running flush operation, even if data remains to be transferred.
Instance Variable client Undocumented
Instance Variable clientIO Undocumented
Instance Variable server Undocumented
Instance Variable serverIO Undocumented
Instance Variable _stop Undocumented
def __init__(self, client, server, clientIO, serverIO):

Undocumented

def flush(self):

Pump until there is no more input or output or until stop is called. This does not run any timers, so don't use it with any code that calls reactor.callLater.

def pump(self):

Move data back and forth.

Returns whether any data was moved.

def stop(self):

Stop a running flush operation, even if data remains to be transferred.

client =

Undocumented

clientIO =

Undocumented

server =

Undocumented

serverIO =

Undocumented

_stop: bool =

Undocumented