[−][src]Module crossfire::mpmc
Re-exports
pub use crate::channel::AsyncRx; |
Structs
LockedWaker | |
ReceiveFuture | |
RecvError | An error returned from the |
RxBlocking | Receiver that dose not support async |
RxFuture | |
SendError | An error returned from the |
SendFuture | |
SharedFutureBoth | |
SharedSenderBRecvF | |
SharedSenderFRecvB | |
TxBlocking | Sender that dose not support async |
TxFuture | |
UnboundedSharedFuture |
Enums
TryRecvError | An error returned from the |
TrySendError | An error returned from the |
Functions
bounded_future_both | Initiate a bounded channel that sender and receiver are async |
bounded_tx_blocking_rx_future | Initiate a bounded channel that sender is blocking, receiver is sync |
bounded_tx_future_rx_blocking | Initiate a bounded channel that sender is async, receiver is blocking |
unbounded_future | Initiate a unbounded channel. Sender will never block, so we use the same TxBlocking for threads |
Type Definitions
RxUnbounded | |
TxUnbounded |