pub struct EmbeddedNetworkInputChannel<C, S> { /* private fields */ }Expand description
The receiving end of a network channel, as the host provides it: a Stream of the messages
its transport delivers, for the channel end C (its generated marker type, under
incoming).
The host agrees to the channel’s configuration and to the stream it delivers:
EmbeddedNetworkInputChannel::new takes the ChannelConfiguration the host acknowledges,
which must match exactly, and the Promises of the stream it delivers, which must meet what
the dataflow relies on, as for an EmbeddedInputChannel. That stream is the sent stream weakened by
the channel’s configuration (a channel that may reorder delivers a NoOrder stream), so it
may be weaker than what the sending end acknowledges. C is inferred from the field the
EmbeddedNetworkInputChannel fills.
Implementations§
Source§impl<C: EmbeddedNetworkChannel, S> EmbeddedNetworkInputChannel<C, S>
impl<C: EmbeddedNetworkChannel, S> EmbeddedNetworkInputChannel<C, S>
Sourcepub fn new<Tr, Ser, O, R>(
inner: S,
channel: ChannelConfiguration<Tr, Ser>,
promises: Promises<O, R>,
) -> Selfwhere
C: ConfiguredAs<Tr, Ser> + SatisfiedBy<O, R>,
pub fn new<Tr, Ser, O, R>(
inner: S,
channel: ChannelConfiguration<Tr, Ser>,
promises: Promises<O, R>,
) -> Selfwhere
C: ConfiguredAs<Tr, Ser> + SatisfiedBy<O, R>,
Wraps a host stream for the channel end C, with the acknowledgement of its
configuration (channel) and the promises of the stream it delivers (promises).
Auto Trait Implementations§
impl<C, S> Freeze for EmbeddedNetworkInputChannel<C, S>
impl<C, S> RefUnwindSafe for EmbeddedNetworkInputChannel<C, S>
impl<C, S> Send for EmbeddedNetworkInputChannel<C, S>
impl<C, S> Sync for EmbeddedNetworkInputChannel<C, S>
impl<C, S> Unpin for EmbeddedNetworkInputChannel<C, S>
impl<C, S> UnsafeUnpin for EmbeddedNetworkInputChannel<C, S>
impl<C, S> UnwindSafe for EmbeddedNetworkInputChannel<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