pub struct WorkerHostRunner(/* private fields */);
Expand description
A runner returned by worker_host()
. Used to handle worker launch
requests.
This may be sent across processes via mesh.
Implementations§
Source§impl WorkerHostRunner
impl WorkerHostRunner
Sourcepub async fn run(self, factory: impl WorkerFactory)
pub async fn run(self, factory: impl WorkerFactory)
Runs the worker host until all corresponding WorkerHost
instances
have been dropped and all workers have exited.
factory
provides the set of possible workers to launch. Typically,
this will be RegisteredWorkers
.
Trait Implementations§
Source§impl Debug for WorkerHostRunner
impl Debug for WorkerHostRunner
Source§impl DefaultEncoding for WorkerHostRunner
impl DefaultEncoding for WorkerHostRunner
Source§impl<'encoding> StructDecodeMetadata<'encoding, Resource> for WorkerHostRunner
impl<'encoding> StructDecodeMetadata<'encoding, Resource> for WorkerHostRunner
Source§impl StructEncodeMetadata<Resource> for WorkerHostRunner
impl StructEncodeMetadata<Resource> for WorkerHostRunner
Auto Trait Implementations§
impl Freeze for WorkerHostRunner
impl !RefUnwindSafe for WorkerHostRunner
impl Send for WorkerHostRunner
impl Sync for WorkerHostRunner
impl Unpin for WorkerHostRunner
impl !UnwindSafe for WorkerHostRunner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> MeshField for T
impl<T> MeshField for T
§impl<T> MeshPayload for T
impl<T> MeshPayload for T
§impl<T> SerializeMessage for Twhere
T: 'static + MeshPayload + Send,
impl<T> SerializeMessage for Twhere
T: 'static + MeshPayload + Send,
§fn compute_message_size(&mut self, sizer: MessageSizer<'_>)
fn compute_message_size(&mut self, sizer: MessageSizer<'_>)
Computes the message size, as in [
MessageEncode::compute_message_size
].§fn write_message(self, writer: MessageWriter<'_, '_, Resource>)
fn write_message(self, writer: MessageWriter<'_, '_, Resource>)
Writes the message, as in [
MessageEncode::write_message
].