pub type JupyterWebSocketReader = SplitStream<JupyterWebSocket>;
Aliased Type§
struct JupyterWebSocketReader(/* private fields */);
Implementations
Source§impl<S> SplitStream<S>
impl<S> SplitStream<S>
Sourcepub fn is_pair_of<Item>(&self, other: &SplitSink<S, Item>) -> bool
pub fn is_pair_of<Item>(&self, other: &SplitSink<S, Item>) -> bool
Returns true
if the SplitStream<S>
and SplitSink<S>
originate from the same call to StreamExt::split
.
Source§impl<S> SplitStream<S>where
S: Unpin,
impl<S> SplitStream<S>where
S: Unpin,
Sourcepub fn reunite<Item>(
self,
other: SplitSink<S, Item>,
) -> Result<S, ReuniteError<S, Item>>where
S: Sink<Item>,
pub fn reunite<Item>(
self,
other: SplitSink<S, Item>,
) -> Result<S, ReuniteError<S, Item>>where
S: Sink<Item>,
Attempts to put the two “halves” of a split Stream + Sink
back
together. Succeeds only if the SplitStream<S>
and SplitSink<S>
are
a matching pair originating from the same call to StreamExt::split
.