nvflare.fuel.hci.chunk module

class ChunkState(expect_seq=1)[source]

Bases: object

is_last()[source]
unpack_header()[source]
class Header(marker, num1, num2)[source]

Bases: object

classmethod from_bytes(buffer: bytes)[source]
to_bytes()[source]
class Receiver(receive_data_func)[source]

Bases: object

receive(data) → bool[source]
class Sender(send_data_func)[source]

Bases: object

close()[source]
send(data)[source]
chunk_it(c: ChunkState, data, cursor: int, process_chunk_func) → ChunkState[source]
get_slice(buf, start: int, length: int)[source]