pub struct EmbeddedNetworkOutputChannel<C, S> { /* private fields */ }Expand description
The sending end of a network channel, as the host provides it: an FnMut sink that hands
each message to the host’s transport, for the channel end C (its generated marker type,
under outgoing).
The host agrees to both inputs of the dataflow’s send: EmbeddedNetworkOutputChannel::new takes the
ChannelConfiguration the host acknowledges, which must match the channel’s exactly, and the
Acknowledgements of the stream the dataflow sends, which must cover every way it may be
weaker than ordered and exactly-once, as for an EmbeddedOutputChannel. C is inferred from the
field the EmbeddedNetworkOutputChannel fills.
Implementations§
Source§impl<C: EmbeddedNetworkChannel, S> EmbeddedNetworkOutputChannel<C, S>
impl<C: EmbeddedNetworkChannel, S> EmbeddedNetworkOutputChannel<C, S>
Sourcepub fn new<Tr, Ser, O, R>(
inner: S,
channel: ChannelConfiguration<Tr, Ser>,
acknowledgements: Acknowledgements<O, R>,
) -> Selfwhere
C: ConfiguredAs<Tr, Ser> + AcknowledgedBy<O, R>,
pub fn new<Tr, Ser, O, R>(
inner: S,
channel: ChannelConfiguration<Tr, Ser>,
acknowledgements: Acknowledgements<O, R>,
) -> Selfwhere
C: ConfiguredAs<Tr, Ser> + AcknowledgedBy<O, R>,
Wraps a host sink for the channel end C, with the acknowledgements of its
configuration (channel) and of the stream sent on it (acknowledgements).
Auto Trait Implementations§
impl<C, S> Freeze for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> RefUnwindSafe for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> Send for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> Sync for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> Unpin for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> UnsafeUnpin for EmbeddedNetworkOutputChannel<C, S>
impl<C, S> UnwindSafe for EmbeddedNetworkOutputChannel<C, S>
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more