nvflare.fuel.f3.streaming.byte_streamer module

class ByteStreamer(cell: CoreCell)[source]

Bases: object

static get_chunk_size()[source]
send(channel: str, topic: str, target: str, headers: dict, stream: Stream, stream_type='byte', secure=False, optional=False) → StreamFuture[source]
class TxTask(channel: str, topic: str, target: str, headers: dict, stream: Stream, secure: bool, optional: bool)[source]

Bases: object