pub fn message_not_ready(&mut self) -> Result<bool, Error> {
        if self.stack_remainings.is_empty() {
            self.buf.drain(..self.parsed_offset);
            self.parsed_tokens = 0;
            self.parsed_offset = 0;
            self.stack_remainings.push(Some(ONE)); // to parse 1 msg next time
        }

        while !self.stack_remainings.is_empty() {
            let mut buf = &self.buf[self.parsed_offset..];
            let token = match next_token(&mut buf) {
                Ok(tok) => tok,
                Err(None) => return Ok(true),
                Err(Some(err)) => return Err(err),
            };
            self.parsed_tokens += 1;
            self.parsed_offset = self.buf.len() - buf.len();

            token.process_stack(&mut self.stack_remainings)?;
        }

        Ok(false)
    }
/// Returns message view stored within the internal buffer on success.
/// Returns `Ok(None)` if more bytes needed to parse.
/// To get next message after this call, you need to call `.consume()`
/// otherwise the same message would be returned again.
///
/// Consume the previous parsed messageand parse remaining bytes
/// to check if new message is ready.
///
/// `Ok(true)` means more bytes are needed to be read to parse a full message.
/// After returning `Ok(false)` it's guaranteed that `.message()` returns `Some(msg)`.
Returns message view stored within the internal buffer on success.
Returns `Ok(None)` if more bytes needed to parse.
To get next message after this call, you need to call `.consume()`
otherwise the same message would be returned again.

Consume the previous parsed messageand parse remaining bytes
to check if new message is ready.

`Ok(true)` means more bytes are needed to be read to parse a full message.
Returns message view stored within the internal buffer on success . Returns ` Ok ( None ) ` if more bytes needed to parse . To get next message after this call you need to call ` . consume () ` otherwise the same message would be returned again . Consume the previous parsed messageand parse remaining bytes to check if new message is ready . ` Ok ( true ) ` means more bytes are needed to be read to parse a full message .
pub fn message_not_ready(&mut self) -> Result<bool, Error> {
        if self.stack_remainings.is_empty() {
            self.buf.drain(..self.parsed_offset);
            self.parsed_tokens = 0;
            self.parsed_offset = 0;
            self.stack_remainings.push(Some(ONE)); // to parse 1 msg next time
        }
        while !self.stack_remainings.is_empty() {
            let mut buf = &self.buf[self.parsed_offset..];
            let token = match next_token(&mut buf) {
                Ok(tok) => tok,
                Err(None) => return Ok(true),
                Err(Some(err)) => return Err(err),
            };
            self.parsed_tokens += 1;
            self.parsed_offset = self.buf.len() - buf.len();
            token.process_stack(&mut self.stack_remainings)?;
        }
        Ok(false)
    }
pub fn message_not_ready ( & mut self ) -> Result < bool , Error > { if self . stack_remainings . is_empty ( ) { self . buf . drain ( .. self . parsed_offset ) ; self . parsed_tokens = 0 ; self . parsed_offset = 0 ; self . stack_remainings . push ( Some ( ONE ) ) ; // to parse 1 msg next time } while ! self . stack_remainings . is_empty ( ) { let mut buf = & self . buf [ self . parsed_offset .. ] ; let token = match next_token ( & mut buf ) { Ok ( tok ) => tok , Err ( None ) => return Ok ( true ) , Err ( Some ( err ) ) => return Err ( err ) , } ; self . parsed_tokens += 1 ; self . parsed_offset = self . buf . len ( ) - buf . len ( ) ; token . process_stack ( & mut self . stack_remainings ) ? ; } Ok ( false ) }
Returns message view stored within the internal buffer on success.
Returns message view stored within the internal buffer on success .
&mut self