Class TokenReader

java.lang.Object
org.infinispan.server.memcached.text.TokenReader
All Implemented Interfaces:
io.netty.util.ByteProcessor
public class TokenReader extends Object implements io.netty.util.ByteProcessor
Reads the next token from the buffer, accepting only valid characters. If a non-valid character is found, the buffer is consumed to the end of the line and an IllegalArgumentException is thrown.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.netty.util.ByteProcessor

    io.netty.util.ByteProcessor.IndexNotOfProcessor, io.netty.util.ByteProcessor.IndexOfProcessor

  • Field Summary

    Fields inherited from interface io.netty.util.ByteProcessor

    FIND_ASCII_SPACE, FIND_COMMA, FIND_CR, FIND_CRLF, FIND_LF, FIND_LINEAR_WHITESPACE, FIND_NON_CR, FIND_NON_CRLF, FIND_NON_LF, FIND_NON_LINEAR_WHITESPACE, FIND_NON_NUL, FIND_NUL, FIND_SEMI_COLON

  • Constructor Summary

    Constructors
    Constructor
    Description
    TokenReader(io.netty.buffer.ByteBuf output)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    TokenReader
    forToken(BitSet token, int bytesAvailable)
     
    io.netty.buffer.ByteBuf
    output()
     
    boolean
    process(byte b)
     
    int
    readBytesSize()
     
    void
    release()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TokenReader

      public TokenReader(io.netty.buffer.ByteBuf output)

  • Method Details

    • release

      public void release()

    • forToken

      public TokenReader forToken(BitSet token, int bytesAvailable)

    • output

      public io.netty.buffer.ByteBuf output()

    • readBytesSize

      public int readBytesSize()

    • process

      public boolean process(byte b) throws Exception
      Specified by:
      process in interface io.netty.util.ByteProcessor
      Throws:
      Exception