nvflare.fuel.f3.streaming.object_streamer module

class ObjectHandler(object_stream_cb: Callable, object_cb: Callable, obj_tasks: dict)

Bases: object

handle_object(future: StreamFuture, *args, **kwargs)

object_done(future: StreamFuture, obj_sid: int, index: int, *args, **kwargs)

class ObjectRxTask(obj_sid: int, channel: str, topic: str, origin: str, headers: dict)

Bases: object

class ObjectStreamer(blob_streamer: BlobStreamer)

Bases: object

register_object_callbacks(channel, topic, object_stream_cb: Callable, object_cb: Callable, *args, **kwargs)

stream_objects(channel: str, topic: str, target: str, headers: dict, iterator: ObjectIterator, secure=False, optional=False) → ObjectStreamFuture

class ObjectTxTask(channel: str, topic: str, target: str, headers: dict, iterator: ObjectIterator, secure: bool, optional: bool)

Bases: object