Enum pikadick::util::encoder_task::Message
source · enum Message {
GetEncoders {
validate: bool,
tx: Sender<Result<Vec<Encoder>>>,
},
Encode {
builder: Box<Builder>,
tx: Sender<Result<Receiver<Result<Event, Error>>>>,
},
Close {
tx: Sender<()>,
},
}
Expand description
A message for the encoder task
Variants§
GetEncoders
Fields
Get encoders available to the application
Encode
Fields
Request an encode
Close
Request a shutdown.
the task will drain the channel until it is empty after recieving this. the task will still accept new messages until it processes this one.
Auto Trait Implementations§
impl !RefUnwindSafe for Message
impl Send for Message
impl Sync for Message
impl Unpin for Message
impl !UnwindSafe for Message
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> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§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>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request