aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src/pubsub/mod.rs
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-191-0/+2
| | | | All tests green
* Update Rust nightly, stable.Dario Nieuwenhuis2025-07-041-4/+4
|
* embassy-sync: fix clear() to wake sendersibuki20032025-01-261-0/+3
|
* Merge pull request #3358 from mammothbane/mainDario Nieuwenhuis2024-10-211-0/+26
|\ | | | | embassy_sync: `Sink` adapter for `pubsub::Pub`
| * embassy_sync: `Sink` adapter for `pubsub::Pub`Nathan Perry2024-09-201-0/+26
| | | | | | | | | | | | | | | | 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-221-0/+16
|
* embassy-sync: fixed some documentation typosOliver Rockstedt2024-05-221-1/+1
|
* Expose new length functions in the subs and pubsDion Dokter2024-05-201-22/+60
|
* 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
|
* Went back to named futures but now with must_useDion Dokter2022-09-291-1/+1
|
* Futures in pub & sub are now awaited instead of returned for better user ↵Dion Dokter2022-09-291-0/+73
| | | | | | compiler diagnostics. Added functions for reading how many messages are available
* sync: flatten module structure.Dario Nieuwenhuis2022-08-221-0/+542