Struct PendingLaunchGuard 

struct PendingLaunchGuard<'a, CF: AbstractChannelFactory> {
    channels: &'a MgrState<CF>,
    handle: Option<PendingChannelHandle>,
    send: Option<Sender<Result<()>>>,
    result: Result<()>,
}

Keeps a pending launch entry and its waiters in sync.

Every exit path from a launch attempt must either remove the pending entry or upgrade it to an open channel, and must notify all waiters with the outcome. This guard makes cancellation and early returns follow the same cleanup path as ordinary failures.

Fields

channels: &'a MgrState<CF>

Channel state used to remove or upgrade the pending entry.

handle: Option<PendingChannelHandle>

Handle to the pending entry, if it has not yet been removed.

send: Option<Sender<Result<()>>>

Sender used to notify tasks waiting on this launch.

result: Result<()>

Result to report to the waiters if the launch ends here.

Implementations

impl<'a, CF: AbstractChannelFactory> PendingLaunchGuard<'a, CF>

fn new( channels: &'a MgrState<CF>, handle: PendingChannelHandle, send: Sender<Result<()>>, ) -> Self

Create a new guard for a pending launch.

fn note_result(&mut self, result: Result<()>)

Record the result that should be reported to any waiters.

fn upgrade_pending_channel_to_open( &mut self, channel: Arc<CF::Channel>, ) -> Result<()>

Replace the pending channel with an open one.

Trait Implementations

impl<'a, CF: AbstractChannelFactory> Drop for PendingLaunchGuard<'a, CF>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.