Struct ControlChannels

Source

struct ControlChannels {
    a2s_listen_r: UnboundedReceiver<(ListenAddr, Sender<Result<()>>)>,
    a2s_connect_r: UnboundedReceiver<(ConnectAddr, Sender<Result<Participant, NetworkConnectError>>)>,
    a2s_scheduler_shutdown_r: Receiver<()>,
    a2s_disconnect_r: UnboundedReceiver<(Pid, (Duration, Sender<Result<(), ParticipantError>>))>,
    b2s_prio_statistic_r: UnboundedReceiver<(Pid, u64, u64)>,
}

Fields§

§a2s_listen_r: UnboundedReceiver<(ListenAddr, Sender<Result<()>>)>§a2s_connect_r: UnboundedReceiver<(ConnectAddr, Sender<Result<Participant, NetworkConnectError>>)>§a2s_scheduler_shutdown_r: Receiver<()>§a2s_disconnect_r: UnboundedReceiver<(Pid, (Duration, Sender<Result<(), ParticipantError>>))>§b2s_prio_statistic_r: UnboundedReceiver<(Pid, u64, u64)>

ControlChannels

Struct ControlChannels Copy item path

Fields§

Trait Implementations§

impl Debug for ControlChannels

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

Auto Trait Implementations§

impl Freeze for ControlChannels

impl !RefUnwindSafe for ControlChannels

impl Send for ControlChannels

impl Sync for ControlChannels

impl Unpin for ControlChannels

impl !UnwindSafe for ControlChannels

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ControlChannels

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,