10000 DRIVERS.md: Broker - clarify Queue becoming full. · Angrite/micropython-async@7d0b3d3 · GitHub
[go: up one dir, main page]

Skip to content

Commit 7d0b3d3

Browse files
committed
DRIVERS.md: Broker - clarify Queue becoming full.
1 parent d059887 commit 7d0b3d3

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

v3/docs/DRIVERS.md

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1132,7 +1132,8 @@ finally:
11321132

11331133
# 9. Message Broker
11341134

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).
11361137

11371138
The `Broker` class provides a flexible means of messaging between running tasks.
11381139
It uses a publish-subscribe model (akin to MQTT) whereby the transmitting task
@@ -1153,7 +1154,8 @@ matching `topic`.
11531154
* `unsubscribe(topic, agent)` The `agent` will stop being triggered.
11541155
* `publish(topic, message)` All `agent` instances subscribed to `topic` will be
11551156
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.
11571159

11581160
The `topic` arg is typically a string but may be any hashable object. A
11591161
`message` is an arbitrary Python object. An `agent` may be any of the following:

v3/docs/PRIMITIVES.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
### For historical reasons documentation for primitives may be found [here](./DRIVERS.md).