Go to the latest version of this document.

# ``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
`KeyError` | If 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
`KeyError` | If there is no such open stream.

_counter: `Iterator[int]` = (source)

Undocumented

_streams: `dict[int, list[bytes]]` = (source)

Undocumented