File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -1132,7 +1132,8 @@ finally:
1132
1132
1133
1133
# 9. Message Broker
1134
1134
1135
- This is under development: please check for updates.
1135
+ This is under development: please check for updates. See
1136
+ [ code] ( https://github.com/peterhinch/micropython-async/blob/master/v3/primitives/broker.py ) .
1136
1137
1137
1138
The ` Broker ` class provides a flexible means of messaging between running tasks.
1138
1139
It uses a publish-subscribe model (akin to MQTT) whereby the transmitting task
@@ -1153,7 +1154,8 @@ matching `topic`.
1153
1154
* ` unsubscribe(topic, agent) ` The ` agent ` will stop being triggered.
1154
1155
* ` publish(topic, message) ` All ` agent ` instances subscribed to ` topic ` will be
1155
1156
triggered, receiving ` topic ` and ` message ` args. Returns ` True ` unless a ` Queue `
1156
- agent has become full, in which case data for that queue has been lost.
1157
+ agent has become full. A ` False ` value indicates that at least one message has
1158
+ been lost.
1157
1159
1158
1160
The ` topic ` arg is typically a string but may be any hashable object. A
1159
1161
` message ` is an arbitrary Python object. An ` agent ` may be any of the following:
Original file line number Diff line number Diff line change
1
+ ### For historical reasons documentation for primitives may be found [ here] ( ./DRIVERS.md ) .
You can’t perform that action at this time.
0 commit comments