pub type ManyIn<T> = EngineStream<T>;Expand description
Pipeline input for streaming-request engines: a trait-object alias around a
stream that carries its own cancellation context (via the
AsyncEngineContextProvider half of [AsyncEngineStream]).
This is the input-side mirror of ManyOut. Both aliases resolve to the
same underlying EngineStream<T> type; the directional names are
documentary. Earlier definitions wrapped the stream in a Context<…>
(Context<DataStream<T>>); that shape was uninstantiable because
DataStream<T> is !Sync while Context<T: Data> requires Sync. The
trait-object form solves that cleanly: the cancellation surface is part of
the trait contract rather than an outer wrapper.
Aliased Type§
pub struct ManyIn<T> { /* private fields */ }