Struct mz_timely_util::builder_async::ConnectedToOne
source · pub struct ConnectedToOne(usize);
Expand description
A marker type representing an input connected to exactly one output.
Tuple Fields§
§0: usize
Trait Implementations§
source§impl<T: Timestamp> InputConnection<T> for ConnectedToOne
impl<T: Timestamp> InputConnection<T> for ConnectedToOne
§type Capability = Capability<T>
type Capability = Capability<T>
The capability type associated with this connection behavior.
source§fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>
fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>
Generates a summary description of the connection behavior given the number of outputs.
source§fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability
fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability
Accepts an input capability.
Auto Trait Implementations§
impl Freeze for ConnectedToOne
impl RefUnwindSafe for ConnectedToOne
impl Send for ConnectedToOne
impl Sync for ConnectedToOne
impl Unpin for ConnectedToOne
impl UnwindSafe for ConnectedToOne
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> 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
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.