twisted.trial._dist.stream.StreamReceiver

class documentation

class StreamReceiver:

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]:

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:

Open a new stream and return its unique identifier.

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

Write to an open stream using its unique identifier.

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

Undocumented

_streams: dict[int, list[bytes]] =

Undocumented