Enum WorkerRpc

pub enum WorkerRpc<T> {
    Stop,
    Restart(FailableRpc<(), T>),
    Inspect(Deferred),
}

Common requests for workers.

Variants

Stop

Tear down.

Restart(FailableRpc<(), T>)

Tear down and send the state necessary to restart on the provided channel.

Inspect(Deferred)

Inspect the worker.

Trait Implementations

impl<T: Debug> Debug for WorkerRpc<T>

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

Formats the value using the given formatter.

impl<T> DefaultEncoding for WorkerRpc<T>

where T: 'static + MeshPayload + Send,

type Encoding = OneofEncoder

The encoding to use for the serialization.

impl<'encoding, T> OneofDecode<'encoding, Resource> for WorkerRpc<T>

where T: 'static + MeshPayload + Send,

fn read_variant( item: &mut InplaceOption<'_, Self>, n: u32, field: FieldReader<'encoding, '_, Resource>, ) -> Result<()>

Read the specified variant from the reader.

impl<T> OneofEncode<Resource> for WorkerRpc<T>

where T: 'static + MeshPayload + Send,

fn write_variant(self, writer: MessageWriter<'_, '_, Resource>)

Write the variant to the writer.

fn compute_variant_size(&mut self, sizer: MessageSizer<'_>)

Compute the size of the variant.