aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src/pubsub
Commit message (Collapse)AuthorAgeFilesLines
* Rustfmt for edition 2024.Dario Nieuwenhuis2025-10-061-1/+1
|
* chore: add more `Debug` impls to `embassy-sync`, particularly on `OnceLock`Curly2025-08-193-0/+11
| | | | All tests green
* Update embassy-sync/src/pubsub/publisher.rsRobin Mueller2025-07-091-1/+1
| | | Co-authored-by: James Munns <[email protected]>
* some minor documentation fixesRobin Mueller2025-07-091-1/+1
|
* Update Rust nightly, stable.Dario Nieuwenhuis2025-07-041-4/+4
|
* Remove futures-util where unnecessaryDániel Buga2025-06-161-1/+1
|
* embassy-sync: fix clear() to wake sendersibuki20032025-01-261-0/+3
|
* Merge pull request #3358 from mammothbane/mainDario Nieuwenhuis2024-10-212-0/+93
|\ | | | | embassy_sync: `Sink` adapter for `pubsub::Pub`
| * embassy_sync: `Sink` adapter for `pubsub::Pub`Nathan Perry2024-09-202-0/+93
| | | | | | | | | | | | | | | | Corresponding to the `Stream` impl for `pubsub::Sub`. Notable difference is that we need a separate adapter type to store the pending item, i.e. we can't `impl Sink for Pub` directly. Instead a method `Pub::sink(&self)` is exposed, which constructs a `PubSink`.
* | embassy-sync: fixed some clippy warningsOliver Rockstedt2024-10-071-2/+2
|/
* embassy_sync/pubsub: fix PubSubBehavior visibilityNathan Perry2024-09-191-28/+28
| | | | | | | | | | | https://github.com/embassy-rs/embassy/pull/2969 appears to have broken direct `publish_immediate()` on `pubsub::Channel`, as it functionally made `PubSubBehavior` private and didn't delegate this method to the new (private) `SealedPubSubBehavior`. This change moves `publish_immediate`, `capacity`, and `is_full` from `SealedPubSubBehavior` to `PubSubBehavior` in order to restore them to `pub` visibility.
* Add Clone and Copy to Error typesdvdsk2024-06-061-1/+1
| | | | | None of them are `non-exaustative`, they are all small enough to be copy (I estimate none are larger than 4 bytes).
* embassy-sync: Add clear function to all channelsOliver Rockstedt2024-05-223-0/+31
|
* embassy-sync: fixed some documentation typosOliver Rockstedt2024-05-221-1/+1
|
* Expose new length functions in the subs and pubsDion Dokter2024-05-203-33/+138
|
* Make behaviour trait sealedDion Dokter2024-05-201-2/+9
|
* embassy-sync: Add capacity, free_capacity, len, is_empty and is_full ↵Oliver Rockstedt2024-05-181-0/+39
| | | | functions to PubSubChannel
* sync: do will_wake check in MultiWakerRegistration.Dario Nieuwenhuis2023-05-261-31/+3
|
* perf(pubsub): Skip clone on last messageRasmus Melchior Jacobsen2023-03-211-4/+28
|
* fix(pubsub): Pop messages which count is 0 after unsubscribeRasmus Melchior Jacobsen2023-03-151-0/+47
|
* Forgot to add space function to immediate publisherDion Dokter2022-10-051-0/+8
|
* Went back to named futures but now with must_useDion Dokter2022-09-293-7/+8
|
* Futures in pub & sub are now awaited instead of returned for better user ↵Dion Dokter2022-09-293-5/+92
| | | | | | compiler diagnostics. Added functions for reading how many messages are available
* sync: flatten module structure.Dario Nieuwenhuis2022-08-223-0/+876