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.

Undocumented

Undocumented