Function decode_tokio

pub fn decode_tokio<Input, P>(
    parser: P,
    input: &mut Input,
    partial_state: &mut P::PartialState,
) -> Result<(Option<P::Output>, usize), <Input as StreamOnce>::Error>
where
    P: Parser<Input>,
    Input: RangeStream,

Decodes input using parser. Like decode but works directly in both tokio_util::Decoder::decode and tokio_util::Decoder::decode_eof

Return Ok(Some(token), committed_data) if there was enough data to finish parsing using parser. Returns Ok(None, committed_data) if input did not contain enough data to finish parsing using parser. Returns Ok(None, 0) if input did not contain enough data to finish parsing using parser.

See examples/async.rs for example usage in a tokio_io::codec::Decoder