twisted.trial._dist.stream.StreamReceiver

class documentation

class StreamReceiver: (source)

View In Hierarchy

Buffering de-multiplexing byte stream receiver.

Method finish Indicate an open stream may receive no further data and return all of its current contents.
Method open Open a new stream and return its unique identifier.
Method write Write to an open stream using its unique identifier.
Class Variable _counter Undocumented
Class Variable _streams Undocumented
def finish(self, streamId): (source)

Indicate an open stream may receive no further data and return all of its current contents.

Parameters
streamId:intUndocumented
Returns
List[bytes]Undocumented
Raises
KeyErrorIf there is no such open stream.
def open(self): (source)

Open a new stream and return its unique identifier.

Returns
intUndocumented
def write(self, streamId, chunk): (source)

Write to an open stream using its unique identifier.

Parameters
streamId:intUndocumented
chunk:bytesUndocumented
Raises
KeyErrorIf there is no such open stream.
_counter: Iterator[int] = (source)

Undocumented

_streams: Dict[int, List[bytes]] = (source)

Undocumented