nvflare.fuel.utils.pipe.pipe module

class EndPoint(get_func, put_func)[source]

Bases: object

Object with put and get functions.

Parameters

  • get_func – get function

  • put_func – put function

get(timeout=None)[source]
put(topic: str, data_bytes)[source]
class Pipe(name)[source]

Bases: object

Base class for communication.

Parameters

name – name of pipe

clear()[source]
x_get(timeout=None)[source]
x_put(topic: str, data_bytes)[source]
y_get(timeout=None)[source]
y_put(topic: str, data_bytes)[source]