Receive OpenRoadCode messages without exposing transport details. More...
Public Member Functions | |
| None | subscribe (self, str topic) |
| Subscribe to a topic or transport-specific topic prefix. | |
| tuple[str, Mapping[str, Any]] | receive (self) |
| Block until one encoded message is received. | |
| None | close (self) |
| Release subscriber resources when the implementation owns any. | |
Receive OpenRoadCode messages without exposing transport details.
| tuple[str, Mapping[str, Any]] messaging.subscriber_if.SubscriberIf.receive | ( | self | ) |
Block until one encoded message is received.
Reimplemented in messaging.zeromq.subscriber.ZeroMqSubscriber.
| None messaging.subscriber_if.SubscriberIf.subscribe | ( | self, | |
| str | topic | ||
| ) |
Subscribe to a topic or transport-specific topic prefix.
| topic | Public topic name or supported transport-specific prefix. |
Reimplemented in messaging.zeromq.subscriber.ZeroMqSubscriber.