Struct veloren_network::scheduler::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)>

Struct veloren_network::scheduler::ControlChannelsCopy 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 veloren_network::scheduler::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>,