Broker
Broker
¶
Bases: ABC
Abstract implementation of a broker for consumer and publisher.
It contains the basic logic to connect to a data stream.
connect(data_stream)
async
¶
Connects to the broker running in StreamPipes.
| PARAMETER | DESCRIPTION |
|---|---|
data_stream |
Contains the meta information (resources) for a data stream.
TYPE:
|
| RETURNS | DESCRIPTION |
|---|---|
None
|
|
disconnect()
abstractmethod
async
¶
Closes the connection to the server.
| RETURNS | DESCRIPTION |
|---|---|
None
|
|