pub struct Reader<R> where
R: Read, {
pub stream: BufReader<R>,
pub receiver: Receiver,
}
This reader bundles an existing stream with a parsing algorithm.
It is used by the client in its .split()
function as the reading component.
the stream to be read from
the parser to parse bytes into messages
Reads a single data frame from the remote endpoint.
Returns an iterator over incoming data frames.
Reads a single message from this receiver.
An iterator over incoming messsages.
This iterator will block until new messages arrive and will never halt.
Closes the receiver side of the connection, will cause all pending and future IO to
return immediately with an appropriate value.
Shuts down both Sender and Receiver, will cause all pending and future IO to
return immediately with an appropriate value.
type Error = !
🔬 This is a nightly-only experimental API. (try_from
)
The type returned in the event of a conversion error.
🔬 This is a nightly-only experimental API. (try_from
)
Immutably borrows from an owned value. Read more
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
type Error = <U as TryFrom<T>>::Error
🔬 This is a nightly-only experimental API. (try_from
)
The type returned in the event of a conversion error.
🔬 This is a nightly-only experimental API. (try_from
)
Mutably borrows from an owned value. Read more
impl<T> Typeable for T where T: Any, | |
Get the TypeId
of this object.