type OutputSession<'a, D> = Session<'a, Timestamp, CapacityContainerBuilder<Vec<(D, Timestamp, Diff)>>, Counter<Timestamp, Vec<(D, Timestamp, Diff)>, Tee<Timestamp, Vec<(D, Timestamp, Diff)>>>>;
Expand description
An output session for vector-based containers of updates D
, using a capacity container builder.
Aliased Type§
struct OutputSession<'a, D> { /* private fields */ }
Implementations
Source§impl<'a, T, CB, P> Session<'a, T, CB, P>where
CB: ContainerBuilder,
T: Eq + Clone + 'a,
P: Push<Message<T, <CB as ContainerBuilder>::Container>> + 'a,
impl<'a, T, CB, P> Session<'a, T, CB, P>where
CB: ContainerBuilder,
T: Eq + Clone + 'a,
P: Push<Message<T, <CB as ContainerBuilder>::Container>> + 'a,
Sourcepub fn give_container(
&mut self,
container: &mut <CB as ContainerBuilder>::Container,
)
pub fn give_container( &mut self, container: &mut <CB as ContainerBuilder>::Container, )
Provide a container at the time specified by the Session. Maintains FIFO order with previously pushed data.