Trait mz_timely_util::builder_async::InputConnection

pub trait InputConnection<T: Timestamp> {
    type Capability;

    // Required methods
    fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>;
    fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability;
}

A trait describing the connection behavior between an input of an operator and zero or more of its outputs.

Required Associated Types

type Capability

The capability type associated with this connection behavior.

Required Methods

fn describe(&self, outputs: usize) -> Vec<Antichain<T::Summary>>

Generates a summary description of the connection behavior given the number of outputs.

fn accept(&self, input_cap: InputCapability<T>) -> Self::Capability

Accepts an input capability.

Implementors

impl<T: Timestamp> InputConnection<T> for ConnectedToOne

type Capability = Capability<T>

impl<T: Timestamp> InputConnection<T> for Disconnected

type Capability = T

impl<const N: usize, T: Timestamp> InputConnection<T> for ConnectedToMany<N>

type Capability = [Capability<T>; N]