Struct ManagedLocalEvent 

pub struct ManagedLocalEvent<T> { /* private fields */ }

An event stored on the heap, with automatically managed storage.

Only used in type names. Instances are created internally by LocalOnceEvent.

Methods from Deref<Target = LocalOnceEvent<T>>

pub fn bind_by_ref( &self, ) -> (LocalOnceSender<RefLocalEvent<'_, T>>, LocalOnceReceiver<RefLocalEvent<'_, T>>)

Returns both the sender and receiver for this event, connected by a shared reference to the event.

Panics

Panics if the event has already been bound to a sender-receiver pair.

Example

use events::LocalOnceEvent;

let event = LocalOnceEvent::<i32>::new();
let (sender, receiver) = event.bind_by_ref();

pub fn bind_by_ref_checked( &self, ) -> Option<(LocalOnceSender<RefLocalEvent<'_, T>>, LocalOnceReceiver<RefLocalEvent<'_, T>>)>

Returns both the sender and receiver for this event, connected by a shared reference to the event.

Returns None if the event has already been bound to a sender-receiver pair.

Example

use events::LocalOnceEvent;

let event = LocalOnceEvent::<i32>::new();
let endpoints = event.bind_by_ref_checked().unwrap();
let endpoints2 = event.bind_by_ref_checked(); // Returns None
assert!(endpoints2.is_none());

pub unsafe fn bind_by_ref_unchecked( &self, ) -> (LocalOnceSender<RefLocalEvent<'_, T>>, LocalOnceReceiver<RefLocalEvent<'_, T>>)

Returns both the sender and receiver for this event, connected by a shared reference to the event.

This method assumes the event is not already bound and skips the check for performance.

Safety

The caller must guarantee the event is not already bound.

Example

use events::LocalOnceEvent;

let event = LocalOnceEvent::<i32>::new();
// We know this is the first and only binding of this event
// SAFETY: We know this is the first and only binding of this event
let (sender, receiver) = unsafe { event.bind_by_ref_unchecked() };

pub fn bind_by_rc( self: &Rc<Self>, ) -> (LocalOnceSender<RcLocalEvent<T>>, LocalOnceReceiver<RcLocalEvent<T>>)

Returns both the sender and receiver for this event, connected by an Rc to the event.

This method requires the event to be wrapped in an Rc when called.

Panics

Panics if the event has already been bound to a sender-receiver pair.

Example

use std::rc::Rc;

use events::LocalOnceEvent;

let event = Rc::new(LocalOnceEvent::<i32>::new());
let (sender, receiver) = event.bind_by_rc();

pub fn bind_by_rc_checked( self: &Rc<Self>, ) -> Option<(LocalOnceSender<RcLocalEvent<T>>, LocalOnceReceiver<RcLocalEvent<T>>)>

Returns both the sender and receiver for this event, connected by an Rc to the event.

Returns None if the event has already been bound to a sender-receiver pair.

This method requires the event to be wrapped in an Rc when called.

Example

use std::rc::Rc;

use events::LocalOnceEvent;

let event = Rc::new(LocalOnceEvent::<i32>::new());
let endpoints = event.bind_by_rc_checked().unwrap();
let endpoints2 = event.bind_by_rc_checked(); // Returns None
assert!(endpoints2.is_none());

pub unsafe fn bind_by_rc_unchecked( self: &Rc<Self>, ) -> (LocalOnceSender<RcLocalEvent<T>>, LocalOnceReceiver<RcLocalEvent<T>>)

Returns both the sender and receiver for this event, connected by an Rc to the event.

This method assumes the event is not already bound and skips the check for performance.

This method requires the event to be wrapped in an Rc when called.

Safety

The caller must ensure that the event is not already bound.

Example

use std::rc::Rc;

use events::LocalOnceEvent;

let event = Rc::new(LocalOnceEvent::<i32>::new());
// We know this is the first and only binding of this event
// SAFETY: We know this is the first and only binding of this event
let (sender, receiver) = unsafe { event.bind_by_rc_unchecked() };

pub unsafe fn bind_by_ptr( self: Pin<&Self>, ) -> (LocalOnceSender<PtrLocalEvent<T>>, LocalOnceReceiver<PtrLocalEvent<T>>)

Returns both the sender and receiver for this event, connected by a raw pointer to the event.

This method requires the event to be pinned when called.

Safety

The caller must ensure that:

• The event remains alive and pinned for the entire lifetime of the sender and receiver.
• The sender and receiver are dropped before the event is dropped.

Panics

Panics if the event has already been bound to a sender-receiver pair.

Example

use events::LocalOnceEvent;

let mut event = Box::pin(LocalOnceEvent::<i32>::new());
// SAFETY: We ensure the event outlives the sender and receiver, see below.
let (sender, receiver) = unsafe { event.as_ref().bind_by_ptr() };

sender.send(42);
let value = futures::executor::block_on(receiver).unwrap();
assert_eq!(value, 42);
// sender and receiver are dropped here, before event

pub unsafe fn bind_by_ptr_checked( self: Pin<&Self>, ) -> Option<(LocalOnceSender<PtrLocalEvent<T>>, LocalOnceReceiver<PtrLocalEvent<T>>)>

Returns both the sender and receiver for this event, connected by a raw pointer to the event.

Returns None if the event has already been bound to a sender-receiver pair.

This method requires the event to be pinned when called.

Safety

The caller must ensure that:

• The event remains alive and pinned for the entire lifetime of the sender and receiver.
• The sender and receiver are dropped before the event is dropped.

Example

use events::LocalOnceEvent;

let mut event = Box::pin(LocalOnceEvent::<i32>::new());
// SAFETY: We ensure the event outlives the sender and receiver
let endpoints = unsafe { event.as_ref().bind_by_ptr_checked() }.unwrap();
let endpoints2 = unsafe { event.as_ref().bind_by_ptr_checked() }; // Returns None
assert!(endpoints2.is_none());

pub unsafe fn bind_by_ptr_unchecked( self: Pin<&Self>, ) -> (LocalOnceSender<PtrLocalEvent<T>>, LocalOnceReceiver<PtrLocalEvent<T>>)

Returns both the sender and receiver for this event, connected by a raw pointer to the event.

This method assumes the event is not already bound and skips the check for performance.

This method requires the event to be pinned when called.

Safety

The caller must ensure that:

• The event is not already bound.
• The event remains alive and pinned for the entire lifetime of the sender and receiver.
• The sender and receiver are dropped before the event is dropped.

Example

use events::LocalOnceEvent;

let mut event = Box::pin(LocalOnceEvent::<i32>::new());
// SAFETY: We ensure the event outlives the sender and receiver
let (sender, receiver) = unsafe { event.as_ref().bind_by_ptr_unchecked() };

pub fn inspect_awaiter(&self, f: impl FnOnce(Option<&Backtrace>))

Uses the provided closure to inspect the backtrace of the current awaiter, if there is an awaiter and if backtrace capturing is enabled.

This method is only available in debug builds (cfg(debug_assertions)). For any data to be present, RUST_BACKTRACE=1 or RUST_LIB_BACKTRACE=1 must be set.

The closure receives None if no one is awaiting the event.

Trait Implementations

impl<T> Clone for ManagedLocalEvent<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for ManagedLocalEvent<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Deref for ManagedLocalEvent<T>

type Target = LocalOnceEvent<T>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> ReflectiveT for ManagedLocalEvent<T>

type T = T

The type T extracted from the type signature.

impl<T> LocalEventRef<T> for ManagedLocalEvent<T>