Struct TokioParallelRuntimeComponents

pub struct TokioParallelRuntimeComponents;

Trait Implementations§

Auto Trait Implementations§

§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Calls U::from(self).

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

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Struct TokioParallelRuntimeComponentsCopy item path

Trait Implementations§

impl DelegateComponent<ChannelCreatorComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideUnboundedChannelType

impl DelegateComponent<ChannelOnceCreatorComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideOneShotChannelType

impl DelegateComponent<ChannelOnceTypeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideOneShotChannelType

impl DelegateComponent<ChannelOnceUserComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideOneShotChannelType

impl DelegateComponent<ChannelTypeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideUnboundedChannelType

impl DelegateComponent<ChannelUserComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideUnboundedChannelType

impl DelegateComponent<ChildProcessStarterComponent> for TokioParallelRuntimeComponents

type Delegate = StartTokioChildProcess

impl DelegateComponent<ChildProcessTypeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideTokioChildProcessType

impl DelegateComponent<ChildProcessWaiterComponent> for TokioParallelRuntimeComponents

type Delegate = WaitChildProcess

impl DelegateComponent<CommandExecutorComponent> for TokioParallelRuntimeComponents

type Delegate = ExecCommandWithNoEnv

impl DelegateComponent<CommandWithEnvsExecutorComponent> for TokioParallelRuntimeComponents

type Delegate = TokioExecCommand

impl DelegateComponent<ConcurrentTaskRunnerComponent> for TokioParallelRuntimeComponents

type Delegate = TokioRunParallelTasks

impl DelegateComponent<DirCreatorComponent> for TokioParallelRuntimeComponents

type Delegate = TokioCreateDir

impl DelegateComponent<FileAsStringReaderComponent> for TokioParallelRuntimeComponents

type Delegate = TokioReadFileAsString

impl DelegateComponent<FileCopierComponent> for TokioParallelRuntimeComponents

type Delegate = TokioCopyFile

impl DelegateComponent<FilePathTypeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideStdPathType

impl DelegateComponent<MutexComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideFuturesMutex

impl DelegateComponent<RandomGeneratorComponent> for TokioParallelRuntimeComponents

type Delegate = ThreadRandomGenerator

impl DelegateComponent<ReceiverStreamerComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideUnboundedChannelType

impl DelegateComponent<SenderClonerComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideUnboundedChannelType

impl DelegateComponent<SleeperComponent> for TokioParallelRuntimeComponents

type Delegate = TokioSleep

impl DelegateComponent<StreamMapperComponent> for TokioParallelRuntimeComponents

type Delegate = BoxedStreamMapper

impl DelegateComponent<StreamTypeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideBoxedStreamType

impl DelegateComponent<StringToFileWriterComponent> for TokioParallelRuntimeComponents

type Delegate = TokioWriteStringToFile

impl DelegateComponent<SubscriptionComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideBoxedSubscription

impl DelegateComponent<TaskSpawnerComponent> for TokioParallelRuntimeComponents

type Delegate = TokioSpawnTask

impl DelegateComponent<TcpPortReserverComponent> for TokioParallelRuntimeComponents

type Delegate = TokioReserveTcpPort

impl DelegateComponent<TimeComponent> for TokioParallelRuntimeComponents

type Delegate = ProvideStdTime

Auto Trait Implementations§

impl Freeze for TokioParallelRuntimeComponents

impl RefUnwindSafe for TokioParallelRuntimeComponents

impl Send for TokioParallelRuntimeComponents

impl Sync for TokioParallelRuntimeComponents

impl Unpin for TokioParallelRuntimeComponents

impl UnwindSafe for TokioParallelRuntimeComponents

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<Runtime, Component, Delegate> BoxedStreamTypeProvider<Runtime> for Componentwhere Runtime: Async, Component: DelegateComponent<StreamTypeComponent, Delegate = Delegate>, Delegate: BoxedStreamTypeProvider<Runtime>,

fn to_boxed_stream<Item>( stream: <Component as ProvideStreamType<Runtime>>::Stream<Item>, ) -> Pin<Box<dyn Stream<Item = Item> + Sync + Send>>where Item: Async,

fn from_boxed_stream<Item>( stream: Pin<Box<dyn Stream<Item = Item> + Sync + Send>>, ) -> <Component as ProvideStreamType<Runtime>>::Stream<Item>where Item: Async,

impl<T> From<T> for T

fn from(t: T) -> T

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

fn into(self) -> U

impl<Runtime, Component, Delegate> OneShotChannelTypeProvider<Runtime> for Componentwhere Component: DelegateComponent<ChannelOnceTypeComponent, Delegate = Delegate>, Delegate: OneShotChannelTypeProvider<Runtime>,

Struct TokioParallelRuntimeComponents

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<Runtime, Component, Delegate> BoxedStreamTypeProvider<Runtime> for Component
where Runtime: Async, Component: DelegateComponent<StreamTypeComponent, Delegate = Delegate>, Delegate: BoxedStreamTypeProvider<Runtime>,

fn to_boxed_stream<Item>( stream: <Component as ProvideStreamType<Runtime>>::Stream<Item>, ) -> Pin<Box<dyn Stream<Item = Item> + Sync + Send>>
where Item: Async,

fn from_boxed_stream<Item>( stream: Pin<Box<dyn Stream<Item = Item> + Sync + Send>>, ) -> <Component as ProvideStreamType<Runtime>>::Stream<Item>
where Item: Async,

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

impl<Runtime, Component, Delegate> OneShotChannelTypeProvider<Runtime> for Component
where Component: DelegateComponent<ChannelOnceTypeComponent, Delegate = Delegate>, Delegate: OneShotChannelTypeProvider<Runtime>,

fn from_oneshot_sender<T>( sender: Sender<T>, ) -> <Component as ProvideChannelOnceType<Runtime>>::SenderOnce<T>
where T: Async,

fn from_oneshot_receiver<T>( receiver: Receiver<T>, ) -> <Component as ProvideChannelOnceType<Runtime>>::ReceiverOnce<T>
where T: Async,

fn to_oneshot_sender<T>( sender: <Component as ProvideChannelOnceType<Runtime>>::SenderOnce<T>, ) -> Sender<T>
where T: Async,

fn to_oneshot_receiver<T>( receiver: <Component as ProvideChannelOnceType<Runtime>>::ReceiverOnce<T>, ) -> Receiver<T>
where T: Async,

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

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

impl<Runtime, Component, Delegate> UnboundedChannelTypeProvider<Runtime> for Component
where Runtime: Async, Component: DelegateComponent<ChannelTypeComponent, Delegate = Delegate>, Delegate: UnboundedChannelTypeProvider<Runtime>,

fn from_unbounded_sender<T>( sender: Arc<Mutex<UnboundedSender<T>>>, ) -> <Component as ProvideChannelType<Runtime>>::Sender<T>
where T: Async,

fn from_unbounded_receiver<T>( receiver: UnboundedReceiver<T>, ) -> <Component as ProvideChannelType<Runtime>>::Receiver<T>
where T: Async,

fn to_unbounded_receiver<T>( receiver: <Component as ProvideChannelType<Runtime>>::Receiver<T>, ) -> UnboundedReceiver<T>
where T: Async,

fn to_unbounded_sender_ref<T>( sender: &<Component as ProvideChannelType<Runtime>>::Sender<T>, ) -> &Arc<Mutex<UnboundedSender<T>>>
where T: Async,

fn to_unbounded_receiver_ref<T>( receiver: &mut <Component as ProvideChannelType<Runtime>>::Receiver<T>, ) -> &mut UnboundedReceiver<T>
where T: Async,

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

impl<A> Async for A
where A: Send + Sync + 'static,