Skip to main content

ConnexaTask

connexa::task

Struct ConnexaTask 

Future
Source 
pub struct ConnexaTask<X, C, S, T = (), K = MemoryKeystore>
where
    C: Send + NetworkBehaviour,
    C::ToSwarm: Debug,
    S: Store,
{
Show 35 fields
    pub swarm: Optional<Swarm<Behaviour<C, S>>>,
    pub command_receiver: Optional<Receiver<Command<T>>>,
    pub context: X,
    pub custom_task_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send + 'static>,
    pub custom_event_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, <C as NetworkBehaviour>::ToSwarm) + Send + 'static>,
    pub swarm_event_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + Send + 'static>,
    pub custom_pollable_callback: Box<dyn Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send + 'static>,
    pub keychain: Keychain<K>,
    pub connection_listeners: Vec<Sender<ConnexaSwarmEvent>>,
    pub listener_addresses: HashMap<ListenerId, Vec<Multiaddr>>,
    pub dht_event_sender: IndexMap<RecordKey, Vec<Sender<DHTEvent>>>,
    pub dht_event_global_sender: Vec<Sender<DHTEvent>>,
    pub dht_put_record_receiver: StreamMap<RecordKey, FutureSet<Receiver<Record>>>,
    pub dht_put_record_global_receiver: FutureSet<Receiver<Record>>,
    pub dht_provider_record_receiver: StreamMap<RecordKey, FutureSet<Receiver<ProviderRecord>>>,
    pub dht_provider_record_global_receiver: FutureSet<Receiver<ProviderRecord>>,
    pub pending_dht_put_record: IndexMap<QueryId, Sender<ConnexaResult<()>>>,
    pub pending_dht_put_provider_record: IndexMap<QueryId, Sender<ConnexaResult<()>>>,
    pub pending_dht_get_record: IndexMap<QueryId, Sender<ConnexaResult<PeerRecord>>>,
    pub pending_dht_get_provider_record: IndexMap<QueryId, Sender<ConnexaResult<HashSet<PeerId>>>>,
    pub pending_dht_find_closest_peer: IndexMap<QueryId, Sender<ConnexaResult<Vec<PeerInfo>>>>,
    pub pending_dht_bootstrap: IndexMap<QueryId, Sender<ConnexaResult<()>>>,
    pub pending_connection: IndexMap<ConnectionId, Sender<ConnexaResult<ConnectionId>>>,
    pub pending_disconnection_by_connection_id: IndexMap<ConnectionId, Sender<ConnexaResult<()>>>,
    pub pending_disconnection_by_peer_id: IndexMap<PeerId, Sender<ConnexaResult<()>>>,
    pub pending_listen_on: IndexMap<ListenerId, Sender<ConnexaResult<ListenerId>>>,
    pub pending_remove_listener: IndexMap<ListenerId, Sender<ConnexaResult<()>>>,
    pub gossipsub_listener: IndexMap<TopicHash, Vec<Sender<GossipsubEvent>>>,
    pub floodsub_listener: IndexMap<Topic, Vec<Sender<FloodsubEvent>>>,
    pub pending_rendezvous_register: IndexMap<(PeerId, Namespace), VecDeque<(Option<u64>, Sender<ConnexaResult<()>>)>>,
    pub pending_rendezvous_discover: IndexMap<(PeerId, Option<Namespace>), VecDeque<(Option<Cookie>, Option<u64>, Sender<ConnexaResult<(Cookie, Vec<(PeerId, Vec<Multiaddr>)>)>>)>>,
    pub gossipsub_can_propagate: FutureMap<(PeerId, MessageId), Receiver<Result<MessageAcceptance>>>,
    pub peerstore_ops: FutureSet<BoxFuture<'static, ()>>,
    pub cleanup_timer: Delay,
    pub cleanup_interval: Duration,

}

Fields§

§swarm: Optional<Swarm<Behaviour<C, S>>>§command_receiver: Optional<Receiver<Command<T>>>§context: X§custom_task_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send + 'static>§custom_event_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, <C as NetworkBehaviour>::ToSwarm) + Send + 'static>§swarm_event_callback: Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + Send + 'static>§custom_pollable_callback: Box<dyn Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send + 'static>§keychain: Keychain<K>§connection_listeners: Vec<Sender<ConnexaSwarmEvent>>§listener_addresses: HashMap<ListenerId, Vec<Multiaddr>>§dht_event_sender: IndexMap<RecordKey, Vec<Sender<DHTEvent>>>

A listener for sending dht events

§dht_event_global_sender: Vec<Sender<DHTEvent>>§dht_put_record_receiver: StreamMap<RecordKey, FutureSet<Receiver<Record>>>§dht_put_record_global_receiver: FutureSet<Receiver<Record>>§dht_provider_record_receiver: StreamMap<RecordKey, FutureSet<Receiver<ProviderRecord>>>§dht_provider_record_global_receiver: FutureSet<Receiver<ProviderRecord>>§pending_dht_put_record: IndexMap<QueryId, Sender<ConnexaResult<()>>>§pending_dht_put_provider_record: IndexMap<QueryId, Sender<ConnexaResult<()>>>§pending_dht_get_record: IndexMap<QueryId, Sender<ConnexaResult<PeerRecord>>>§pending_dht_get_provider_record: IndexMap<QueryId, Sender<ConnexaResult<HashSet<PeerId>>>>§pending_dht_find_closest_peer: IndexMap<QueryId, Sender<ConnexaResult<Vec<PeerInfo>>>>§pending_dht_bootstrap: IndexMap<QueryId, Sender<ConnexaResult<()>>>§pending_connection: IndexMap<ConnectionId, Sender<ConnexaResult<ConnectionId>>>§pending_disconnection_by_connection_id: IndexMap<ConnectionId, Sender<ConnexaResult<()>>>§pending_disconnection_by_peer_id: IndexMap<PeerId, Sender<ConnexaResult<()>>>§pending_listen_on: IndexMap<ListenerId, Sender<ConnexaResult<ListenerId>>>§pending_remove_listener: IndexMap<ListenerId, Sender<ConnexaResult<()>>>§gossipsub_listener: IndexMap<TopicHash, Vec<Sender<GossipsubEvent>>>§floodsub_listener: IndexMap<Topic, Vec<Sender<FloodsubEvent>>>§pending_rendezvous_register: IndexMap<(PeerId, Namespace), VecDeque<(Option<u64>, Sender<ConnexaResult<()>>)>>§pending_rendezvous_discover: IndexMap<(PeerId, Option<Namespace>), VecDeque<(Option<Cookie>, Option<u64>, Sender<ConnexaResult<(Cookie, Vec<(PeerId, Vec<Multiaddr>)>)>>)>>§gossipsub_can_propagate: FutureMap<(PeerId, MessageId), Receiver<Result<MessageAcceptance>>>§peerstore_ops: FutureSet<BoxFuture<'static, ()>>§cleanup_timer: Delay§cleanup_interval: Duration

Implementations§

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_autonat_v1_command(&mut self, command: AutonatCommand)

Source

pub fn process_autonat_v1_event(&mut self, event: AutonatV1Event)

Source

pub fn process_autonat_v2_client_event(&mut self, event: AutonatV2ClientEvent)

Source

pub fn process_autonat_v2_server_event(&mut self, event: AutonatV2ServerEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_dcutr_event(&mut self, event: DcutrEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_floodsub_command(&mut self, command: FloodsubCommand)

Source

pub fn process_floodsub_event(&mut self, event: Event)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_gossipsub_command(&mut self, command: GossipsubCommand)

Source

pub fn process_gossipsub_event(&mut self, event: Event)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_identify_event(&mut self, event: IdentifyEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_kademlia_command(&mut self, command: DHTCommand)

Source

pub fn process_kademlia_event(&mut self, event: KademliaEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_mdns_event(&mut self, event: MdnsEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_ping_event(&mut self, event: PingEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_autorelay_commands(&mut self, command: AutoRelayCommand)

Source

pub fn process_relay_client_event(&mut self, event: RelayClientEvent)

Source

pub fn process_relay_server_event(&mut self, event: RelayServerEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_relay_server_command(&mut self, command: RelayServerCommand)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_rendezvous_command(&mut self, command: RendezvousCommand)

Source

pub fn process_rendezvous_server_event(&mut self, event: RendezvousServerEvent)

Source

pub fn process_rendezvous_client_event(&mut self, event: RendezvousClientEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_request_response_command( &mut self, command: RequestResponseCommand, )

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_stream_command(&mut self, command: StreamCommand)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_swarm_event(&mut self, event: SwarmEvent<BehaviourEvent<C, S>>)

Source

pub fn process_swarm_behaviour_event(&mut self, event: BehaviourEvent<C, S>)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn process_upnp_event(&mut self, event: UpnpEvent)

Source§

impl<X, C, S, T, K> ConnexaTask<X, C, S, T, K>
where X: Default + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, S: Store,

Source

pub fn new(swarm: Swarm<Behaviour<C, S>>, keychain: Keychain<K>) -> Self

Source

pub fn set_context(&mut self, context: X)

Source

pub fn set_command_receiver(&mut self, command_receiver: Receiver<Command<T>>)

Source

pub fn set_event_callback<F>(&mut self, callback: F)
where F: Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, C::ToSwarm) + Send + 'static,

Source

pub fn set_task_callback<F>(&mut self, callback: F)
where F: Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send + 'static,

Source

pub fn set_swarm_event_callback<F>(&mut self, callback: F)
where F: Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + 'static + Send,

Source

pub fn set_pollable_callback<F>(&mut self, callback: F)
where F: Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send + 'static,

Source

pub fn process_command(&mut self, command: Command<T>)

Trait Implementations§

Source§

impl<X, C, S, T, K> Future for ConnexaTask<X, C, S, T, K>
where X: Default + Unpin + Send + 'static, C: Send + NetworkBehaviour, C::ToSwarm: Debug, T: 'static, S: Store,

Source§

type Output = ()

The type of value produced on completion.
Source§

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more

Auto Trait Implementations§

§

impl<X, C, S, T = (), K = MemoryKeystore> !Freeze for ConnexaTask<X, C, S, T, K>

§

impl<X, C, S, T = (), K = MemoryKeystore> !RefUnwindSafe for ConnexaTask<X, C, S, T, K>

§

impl<X, C, S, T = (), K = MemoryKeystore> !Sync for ConnexaTask<X, C, S, T, K>

§

impl<X, C, S, T = (), K = MemoryKeystore> !UnwindSafe for ConnexaTask<X, C, S, T, K>

§

impl<X, C, S, T, K> Send for ConnexaTask<X, C, S, T, K>
where Optional<Swarm<Behaviour<C, S>>>: Send, Optional<Receiver<Command<T>>>: Send, X: Send, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send>: Send, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, <C as NetworkBehaviour>::ToSwarm) + Send>: Send, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + Send>: Send, Box<dyn Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send>: Send, Keychain<K>: Send,

§

impl<X, C, S, T, K> Unpin for ConnexaTask<X, C, S, T, K>
where Optional<Swarm<Behaviour<C, S>>>: Unpin, Optional<Receiver<Command<T>>>: Unpin, X: Unpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send>: Unpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, <C as NetworkBehaviour>::ToSwarm) + Send>: Unpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + Send>: Unpin, Box<dyn Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send>: Unpin, Keychain<K>: Unpin,

§

impl<X, C, S, T, K> UnsafeUnpin for ConnexaTask<X, C, S, T, K>
where Optional<Swarm<Behaviour<C, S>>>: UnsafeUnpin, Optional<Receiver<Command<T>>>: UnsafeUnpin, X: UnsafeUnpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, T) + Send>: UnsafeUnpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X, <C as NetworkBehaviour>::ToSwarm) + Send>: UnsafeUnpin, Box<dyn Fn(&mut Swarm<Behaviour<C, S>>, &Keychain<K>, &SwarmEvent<BehaviourEvent<C, S>>, &mut X) + Send>: UnsafeUnpin, Box<dyn Fn(&mut Context<'_>, &mut Swarm<Behaviour<C, S>>, &Keychain<K>, &mut X) -> Poll<()> + Send>: UnsafeUnpin, Keychain<K>: UnsafeUnpin,

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T
where T: Future + ?Sized,

Source§

fn map<U, F>(self, f: F) -> Map<Self, F> ⓘ
where F: FnOnce(Self::Output) -> U, Self: Sized,

Map this future’s output to a different type, returning a new future of the resulting type. Read more
Source§

fn map_into<U>(self) -> MapInto<Self, U> ⓘ
where Self::Output: Into<U>, Self: Sized,

Map this future’s output to a different type, returning a new future of the resulting type. Read more
Source§

fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> ⓘ
where F: FnOnce(Self::Output) -> Fut, Fut: Future, Self: Sized,

Chain on a computation for when a future finished, passing the result of the future to the provided closure f. Read more
Source§

fn left_future<B>(self) -> Either<Self, B> ⓘ
where B: Future<Output = Self::Output>, Self: Sized,

Wrap this future in an Either future, making it the left-hand variant of that Either. Read more
Source§

fn right_future<A>(self) -> Either<A, Self> ⓘ
where A: Future<Output = Self::Output>, Self: Sized,

Wrap this future in an Either future, making it the right-hand variant of that Either. Read more
Source§

fn into_stream(self) -> IntoStream<Self>
where Self: Sized,

Convert this future into a single element stream. Read more
Source§

fn flatten(self) -> Flatten<Self> ⓘ
where Self::Output: Future, Self: Sized,

Flatten the execution of this future when the output of this future is itself another future. Read more
Source§

fn flatten_stream(self) -> FlattenStream<Self>
where Self::Output: Stream, Self: Sized,

Flatten the execution of this future when the successful result of this future is a stream. Read more
Source§

fn fuse(self) -> Fuse<Self> ⓘ
where Self: Sized,

Fuse a future such that poll will never again be called once it has completed. This method can be used to turn any Future into a FusedFuture. Read more
Source§

fn inspect<F>(self, f: F) -> Inspect<Self, F> ⓘ
where F: FnOnce(&Self::Output), Self: Sized,

Do something with the output of a future before passing it on. Read more
Source§

fn catch_unwind(self) -> CatchUnwind<Self> ⓘ
where Self: Sized + UnwindSafe,

Catches unwinding panics while polling the future. Read more
Source§

fn shared(self) -> Shared<Self> ⓘ
where Self: Sized, Self::Output: Clone,

Create a cloneable handle to this future where all handles will resolve to the same result. Read more
Source§

fn remote_handle(self) -> (Remote<Self>, RemoteHandle<Self::Output>)
where Self: Sized,

Turn this future into a future that yields () on completion and sends its output to another future on a separate task. Read more
Source§

fn boxed<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + Send + 'a>>
where Self: Sized + Send + 'a,

Wrap the future in a Box, pinning it. Read more
Source§

fn boxed_local<'a>(self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a>>
where Self: Sized + 'a,

Wrap the future in a Box, pinning it. Read more
Source§

fn unit_error(self) -> UnitError<Self> ⓘ
where Self: Sized,

Turns a Future<Output = T> into a TryFuture<Ok = T, Error = ()>.
Source§

fn never_error(self) -> NeverError<Self> ⓘ
where Self: Sized,

Turns a Future<Output = T> into a TryFuture<Ok = T, Error = Never>.
Source§

fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output>
where Self: Unpin,

A convenience for calling Future::poll on Unpin future types.
Source§

fn now_or_never(self) -> Option<Self::Output>
where Self: Sized,

Evaluates and consumes the future, returning the resulting output if the future is ready after the first call to Future::poll. Read more
Source§

impl<T> FutureExt for T
where T: Future + ?Sized,

Source§

fn with_cancellation_token( self, cancellation_token: &CancellationToken, ) -> WithCancellationTokenFuture<'_, Self>
where Self: Sized,

Similar to CancellationToken::run_until_cancelled, but with the advantage that it is easier to write fluent call chains. Read more
Source§

fn with_cancellation_token_owned( self, cancellation_token: CancellationToken, ) -> WithCancellationTokenFutureOwned<Self>
where Self: Sized,

Similar to CancellationToken::run_until_cancelled_owned, but with the advantage that it is easier to write fluent call chains. Read more
Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

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

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

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

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<F> IntoFuture for F
where F: Future,

Source§

type Output = <F as Future>::Output

The output that the future will produce on completion.
Source§

type IntoFuture = F

Which kind of future are we turning this into?
Source§

fn into_future(self) -> <F as IntoFuture>::IntoFuture

Creates a future from a value. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

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

Initializes a with the given initializer. Read more
Source§

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

Dereferences the given pointer. Read more
Source§

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

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> TimeoutExt for T

Source§

fn timeout(self, duration: Duration) -> Timeout<Self> ⓘ

Requires a Future or Stream to complete before the specific duration has elapsed. Read more
Source§

impl<T> TimeoutFutureExt for T
where T: Future,

Source§

fn timeout(self, duration: Duration) -> Timeout<Self> ⓘ

Requires a Future to complete before the specific duration has elapsed.
Source§

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

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more