Class MessageInputStream

java.lang.Object
java.io.InputStream
org.eclipse.jetty.websocket.common.message.MessageInputStream
All Implemented Interfaces:
Closeable, AutoCloseable, MessageAppender

public class MessageInputStream extends InputStream implements MessageAppender
Support class for reading a (single) WebSocket BINARY message via a InputStream.

An InputStream that can access a queue of ByteBuffer payloads, along with expected InputStream blocking behavior.

  • Field Details

    • LOG

      private static final org.eclipse.jetty.util.log.Logger LOG
    • EOF

      private static final ByteBuffer EOF
    • session

      private final Session session
    • bufferPool

      private final org.eclipse.jetty.io.ByteBufferPool bufferPool
    • buffers

      private final BlockingDeque<ByteBuffer> buffers
    • timeoutMs

      private final long timeoutMs
    • activeBuffer

      private ByteBuffer activeBuffer
    • suspendToken

      private SuspendToken suspendToken
    • state

      private MessageInputStream.State state
  • Constructor Details

    • MessageInputStream

      public MessageInputStream(Session session)
    • MessageInputStream

      public MessageInputStream(Session session, int timeoutMs)
  • Method Details