twisted.internet.test.test_endpoints.MemoryProcessTransport

class documentation

class MemoryProcessTransport(StringTransportWithDisconnection):

Constructor: MemoryProcessTransport(protocol)

Implements interfaces: twisted.internet.interfaces.IProcessTransport

A fake IProcessTransport provider to be used in tests.

Method	`__init__`	Undocumented
Method	`closeChildFD`	Close a file descriptor which is connected to the child process, identified by its FD in the child process.
Method	`closeStderr`	Close stderr.
Method	`closeStdin`	Close stdin after all data has been written out.
Method	`closeStdout`	Close stdout.
Method	`pid`	From before `IProcessProtocol.makeConnection` is called to before `IProcessProtocol.processEnded` is called, `pid` is an `int` giving the platform process ID of this process. `pid` is `None` at all other times.
Method	`signalProcess`	Send a signal to the process.
Method	`writeToChild`	Similar to `ITransport.write` but also allows the file descriptor in the child process which will receive the bytes to be specified.
Instance Variable	`closedChildFDs`	Undocumented
Instance Variable	`protocol`	Undocumented
Instance Variable	`signals`	Undocumented

Inherited from StringTransportWithDisconnection:

Method	`loseConnection`	Close the connection. Does nothing besides toggle the `disconnecting` instance variable to `True`.
Instance Variable	`connected`	Undocumented

Inherited from StringTransport (via StringTransportWithDisconnection):

Method	`abortConnection`	Abort the connection. Same as `loseConnection`, but also toggles the `aborted` instance variable to `True`.
Method	`clear`	Discard all data written to this transport so far.
Method	`getHost`	Similar to getPeer, but returns an address describing this side of the connection.
Method	`getPeer`	Get the remote address of this connection.
Method	`pauseProducing`	Pause producing data.
Method	`registerProducer`	Register to receive data from a producer.
Method	`resumeProducing`	Resume producing data.
Method	`stopProducing`	Stop producing data.
Method	`unregisterProducer`	Stop consuming data from a producer, without disconnecting.
Method	`value`	Retrieve all data which has been buffered by this transport.
Method	`write`	Write some data to the physical connection, in sequence, in a non-blocking fashion.
Method	`writeSequence`	Write an iterable of byte strings to the physical connection.
Instance Variable	`disconnected`	A `bool` which is `False` until `abortConnection` is called, then `True`.
Instance Variable	`disconnecting`	A `bool` which is `False` until `loseConnection` is called, then `True`.
Instance Variable	`hostAddr`	`None` or an object which will be returned as the host address of this transport. If `None`, a nasty tuple will be returned instead.
Instance Variable	`io`	A `io.BytesIO` which holds the data which has been written to this transport since the last call to `clear`. Use `value` instead of accessing this directly.
Instance Variable	`peerAddr`	`None` or an object which will be returned as the peer address of this transport. If `None`, a nasty tuple will be returned instead.
Instance Variable	`producer`	If a producer is currently registered, `producer` is a reference to it. Otherwise, `None`.
Instance Variable	`producerState`	The state of this `StringTransport` in its capacity as an `IPushProducer`. One of `'producing'`, `'paused'`, or `'stopped'`.
Instance Variable	`streaming`	If a producer is currently registered, `streaming` refers to the value of the second parameter passed to `registerProducer`.
Method	`_checkState`	Undocumented
Instance Variable	`_lenient`	By default `StringTransport` enforces that `resumeProducing` is not called after the connection is lost. This is to ensure that any code that does call `resumeProducing` after the connection is lost is not blindly expecting ...

def __init__(self, protocol=None): ¶

overrides twisted.internet.testing.StringTransport.__init__

Undocumented

def closeChildFD(self, fd): ¶