aboutsummaryrefslogtreecommitdiff
path: root/embassy-sync/src
Commit message (Collapse)AuthorAgeFilesLines
...
* remove from senderBronson2025-01-201-11/+0
|
* added remove_if to priority channelBronson2025-01-201-0/+42
|
* feat: add dynamic dispatch variants of pipeUlf Lilleengen2025-01-151-0/+273
|
* Desugar some async fnsDániel Buga2024-12-304-20/+20
|
* Generalize AtomicWakerDániel Buga2024-11-221-10/+32
|
* remove optionBronson2024-11-101-3/+3
|
* fix formattingBronson2024-11-101-1/+1
|
* added watch new_with()Bronson2024-11-101-15/+27
|
* add default data to watch new()Bronson2024-11-101-16/+16
|
* 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-073-3/+4
| |
* | Add capacity, free_capacity, clear, len, is_empty and is_full functions to ↵Oliver Rockstedt2024-10-071-0/+84
| | | | | | | | priority_channel::{Sender, Receiver}
* | Add capacity, free_capacity, clear, len, is_empty and is_full functions to ↵Oliver Rockstedt2024-10-071-0/+84
| | | | | | | | Channel::{Sender, Receiver}
* | Merge pull request #3393 from sourcebox/sync-additionsDario Nieuwenhuis2024-10-061-3/+88
|\ \ | | | | | | | | | embassy-sync: add clear, len, is_empty and is_full functions to zerocopy_channel
| * | embassy-sync: renamed field len to capacity on zerocopy_channel stateOliver Rockstedt2024-10-061-5/+6
| | |
| * | embassy-sync: fix len calculation for zerocopy_channelOliver Rockstedt2024-10-061-1/+9
| | |
| * | embassy-sync: add clear, len, is_empty and is_full functions to zerocopy_channelOliver Rockstedt2024-10-051-0/+76
| | |
* | | docs: fix Sender/Receiver typoChris Maniewski2024-10-051-2/+2
|/ /
* | Reverse generics order, remove spin_getPeter Krull2024-09-241-26/+2
| |
* | Added SealedWatchBehavior to limit access to core functionsPeter Krull2024-09-231-66/+71
| |
* | Discontinue peek, add AnonReceiverPeter Krull2024-09-231-151/+289
| |
* | Merge branch 'embassy-rs:main' into multi-signalPeter Krull2024-09-2315-77/+1806
|\|
| * 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.
| * embassy-sync: more unit-test for LazyLockwanglei2024-07-311-0/+47
| | | | | | | | Signed-off-by: wanglei <[email protected]>
| * embassy-sync: fix the data of LazyLock never dropwanglei2024-07-311-10/+31
| | | | | | | | | | | | | | | | | | Using `union` can save more space. And the `MaybeUninit<T>` will never drop the T, when dropping the `MaybeUninit<T>`. Fixed it. Signed-off-by: wanglei <[email protected]>
| * embassy-sync: add LazyLockSamuel Tardieu2024-07-292-0/+85
| | | | | | | | `LazyLock` is inspired by Rust 1.80.0's `std::sync::LazyLock` type.
| * Reduced define for 'unreachable!' to a single macro ruleTarun Singh2024-07-171-10/+6
| |
| * Add collapse_debuginfo to fmt.rs macros.Dario Nieuwenhuis2024-06-171-0/+17
| | | | | | | | | | | | This makes location info in defmt logs point to the code calling the macro, instead of always to fmt.rs as before. Fix works with nightlies starting with today's, and stable 1.81+.
| * Merge pull request #3054 from dvdsk/clonable-errorsDario Nieuwenhuis2024-06-091-1/+1
| |\ | | | | | | | | | Add Clone and Copy to Error types
| | * 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: remove T: Send for Signal<M, T>Jesse Stuart2024-06-051-1/+1
| |/
| * Emit cargo:rustc-check-cfg instructions from build.rsJan Špaček2024-05-301-1/+1
| |
| * embassy-sync: Add clear function to all channelsOliver Rockstedt2024-05-225-0/+49
| |
| * embassy-sync: fixed some documentation typosOliver Rockstedt2024-05-223-5/+5
| |
| * embassy-sync: fixed some clippy warningsOliver Rockstedt2024-05-214-8/+8
| |
| * 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
| * embassy-sync: Add capacity, free_capacity, len, is_empty and is_full ↵Oliver Rockstedt2024-05-181-0/+39
| | | | | | | | functions to PriorityChannel
| * embassy-sync: Add capacity and free_capacity functions to ChannelOliver Rockstedt2024-05-181-0/+12
| |
| * Fix: typoQWS2024-05-101-1/+1
| |
| * embassy_sync::Mutex: Implement traits to match stdW Etheredge2024-05-051-1/+77
| |
| * Adding ready_to_receive to Channel and Receivernerwalt2024-04-191-0/+35
| | | | | | | | Adding ReceiveReadyFuture
| * Add map methodCaio2024-04-141-0/+133
| |
| * embassy-sync: Add len, is_empty and is_full functions to Channel.Oliver Rockstedt2024-04-081-0/+27
| |
| * Fix `FairSemaphore` bugsAlex Moon2024-04-031-34/+102
| | | | | | | | | | - `acquire` and `acquire_all` futures were `!Send`, even for `M: RawMutex + Send` due to the captured `Cell`. - If multiple `acquire` tasks were queued, waking the first would not wake the second, even if there were permits remaining after the first `acquire` completed.
| * Semaphore synchronization primitiveAlex Moon2024-03-302-0/+705
| | | | | | | | This provides both a "greedy" and "fair" async semaphore implementation.
| * Merge pull request #2651 from peterkrull/once_lockUlf Lilleengen2024-03-222-0/+237
| |\ | | | | | | | | | Add `OnceLock` sync primitive
| | * This one is for ci/rustfmtPeter Krull2024-03-031-2/+1
| | |
generated by cgit (git 2.34.1) at 2026-04-06 04:48:20 +0000