twisted.trial._dist.stream

module documentation

Buffer byte streams.

Class	`StreamOpen`	Open a new stream.
Class	`StreamReceiver`	Buffering de-multiplexing byte stream receiver.
Class	`StreamWrite`	Write a chunk of data to a stream.
Function	`chunk`	Break a byte string into pieces of no more than ``chunkSize`` length.
Async Function	`stream`	Send the given stream chunks, one by one, over the given connection.
Type Variable	`T`	Undocumented

def chunk(data: bytes, chunkSize: int) -> Iterator[bytes]: ¶

Break a byte string into pieces of no more than ``chunkSize`` length.

Parameters
data:`bytes`	The byte string.
chunkSize:`int`	The maximum length of the resulting pieces. All pieces except possibly the last will be this length.
Returns
`Iterator[bytes]`	The pieces.

async def stream(amp: AMP, chunks: Iterator[bytes]) -> int: ¶

Send the given stream chunks, one by one, over the given connection.

The chunks are sent using StreamWrite over a stream opened using StreamOpen.

Returns
`int`	The identifier of the stream over which the chunks were sent.

Undocumented

Value

TypeVar('T')