pub struct QueueNextOpts {
pub names: Option<Vec<String>>,
pub timeout: Option<Duration>,
pub signal: Option<CancellationToken>,
pub completable: bool,
}Fields§
§names: Option<Vec<String>>§timeout: Option<Duration>§signal: Option<CancellationToken>§completable: boolTrait Implementations§
Source§impl Clone for QueueNextOpts
impl Clone for QueueNextOpts
Source§impl Debug for QueueNextOpts
impl Debug for QueueNextOpts
Auto Trait Implementations§
impl Freeze for QueueNextOpts
impl RefUnwindSafe for QueueNextOpts
impl Send for QueueNextOpts
impl Sync for QueueNextOpts
impl Unpin for QueueNextOpts
impl UnsafeUnpin for QueueNextOpts
impl UnwindSafe for QueueNextOpts
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> ErasedDestructor for Twhere
T: 'static,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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