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: int) -> List[bytes]: (source)

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

Raises
KeyErrorIf there is no such open stream.
def open(self) -> int: (source)

Open a new stream and return its unique identifier.

def write(self, streamId: int, chunk: bytes): (source)

Write to an open stream using its unique identifier.

Raises
KeyErrorIf there is no such open stream.
_counter: Iterator[int] = (source)

Undocumented

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

Undocumented