Class EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel

  • All Implemented Interfaces:
    io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.handler.codec.http2.Http2StreamChannel, io.netty.util.AttributeMap, java.lang.Comparable<io.netty.channel.Channel>
    Enclosing class:
    EspressoHttp2MultiplexHandler

    public class EspressoHttp2MultiplexHandler.EspressoHttp2MultiplexHandlerStreamChannel
    extends io.netty.util.DefaultAttributeMap
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface io.netty.channel.Channel

        io.netty.channel.Channel.Unsafe
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void addChannelToReadCompletePendingQueue()  
      io.netty.buffer.ByteBufAllocator alloc()  
      io.netty.channel.ChannelFuture bind​(java.net.SocketAddress localAddress)  
      io.netty.channel.ChannelFuture bind​(java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)  
      long bytesBeforeUnwritable()  
      long bytesBeforeWritable()  
      io.netty.channel.ChannelFuture close()  
      io.netty.channel.ChannelFuture close​(io.netty.channel.ChannelPromise promise)  
      io.netty.channel.ChannelFuture closeFuture()  
      int compareTo​(io.netty.channel.Channel o)  
      io.netty.channel.ChannelConfig config()  
      io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress)  
      io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress, io.netty.channel.ChannelPromise promise)  
      io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)  
      io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)  
      boolean containsUpgradeHandler()  
      io.netty.channel.ChannelFuture deregister()  
      io.netty.channel.ChannelFuture deregister​(io.netty.channel.ChannelPromise promise)  
      io.netty.channel.ChannelFuture disconnect()  
      io.netty.channel.ChannelFuture disconnect​(io.netty.channel.ChannelPromise promise)  
      boolean equals​(java.lang.Object o)  
      io.netty.channel.EventLoop eventLoop()  
      io.netty.channel.Channel flush()  
      protected void flush0​(io.netty.channel.ChannelHandlerContext ctx)  
      int hashCode()  
      io.netty.channel.ChannelId id()  
      void init()  
      void init​(io.netty.handler.codec.http2.Http2FrameCodec.DefaultHttp2FrameStream stream, int id)  
      boolean isActive()  
      boolean isCloseInProgress()  
      boolean isExceptionCaught()  
      boolean isOpen()  
      protected boolean isParentReadInProgress()  
      boolean isReadyToRecycle()  
      boolean isRegistered()  
      boolean isWritable()  
      java.net.SocketAddress localAddress()  
      io.netty.channel.ChannelMetadata metadata()  
      io.netty.channel.ChannelFuture newFailedFuture​(java.lang.Throwable cause)  
      io.netty.channel.ChannelProgressivePromise newProgressivePromise()  
      io.netty.channel.ChannelPromise newPromise()  
      io.netty.channel.ChannelFuture newSucceededFuture()  
      io.netty.channel.Channel parent()  
      protected io.netty.channel.ChannelHandlerContext parentContext()  
      io.netty.channel.ChannelPipeline pipeline()  
      io.netty.channel.Channel read()  
      java.net.SocketAddress remoteAddress()  
      void reset()  
      void setCloseInProgress​(boolean closeIsInProgress)  
      void setExceptionCaught​(boolean exceptionCaught)  
      void setReadyToRecycle​(boolean readyToRecycle)  
      io.netty.handler.codec.http2.Http2FrameStream stream()  
      java.lang.String toString()  
      io.netty.channel.Channel.Unsafe unsafe()  
      io.netty.channel.ChannelPromise voidPromise()  
      io.netty.channel.ChannelFuture write​(java.lang.Object msg)  
      io.netty.channel.ChannelFuture write​(java.lang.Object msg, io.netty.channel.ChannelPromise promise)  
      protected io.netty.channel.ChannelFuture write0​(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg)  
      io.netty.channel.ChannelFuture writeAndFlush​(java.lang.Object msg)  
      io.netty.channel.ChannelFuture writeAndFlush​(java.lang.Object msg, io.netty.channel.ChannelPromise promise)  
      • Methods inherited from class io.netty.util.DefaultAttributeMap

        attr, hasAttr
      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface io.netty.util.AttributeMap

        attr, hasAttr
    • Method Detail

      • init

        public void init()
      • isParentReadInProgress

        protected boolean isParentReadInProgress()
      • addChannelToReadCompletePendingQueue

        protected void addChannelToReadCompletePendingQueue()
      • parentContext

        protected io.netty.channel.ChannelHandlerContext parentContext()
      • init

        public void init​(io.netty.handler.codec.http2.Http2FrameCodec.DefaultHttp2FrameStream stream,
                         int id)
      • reset

        public void reset()
      • containsUpgradeHandler

        public boolean containsUpgradeHandler()
      • isReadyToRecycle

        public boolean isReadyToRecycle()
      • setReadyToRecycle

        public void setReadyToRecycle​(boolean readyToRecycle)
      • isExceptionCaught

        public boolean isExceptionCaught()
      • setExceptionCaught

        public void setExceptionCaught​(boolean exceptionCaught)
      • isCloseInProgress

        public boolean isCloseInProgress()
      • setCloseInProgress

        public void setCloseInProgress​(boolean closeIsInProgress)
      • stream

        public io.netty.handler.codec.http2.Http2FrameStream stream()
        Specified by:
        stream in interface io.netty.handler.codec.http2.Http2StreamChannel
      • metadata

        public io.netty.channel.ChannelMetadata metadata()
        Specified by:
        metadata in interface io.netty.channel.Channel
      • config

        public io.netty.channel.ChannelConfig config()
        Specified by:
        config in interface io.netty.channel.Channel
      • isOpen

        public boolean isOpen()
        Specified by:
        isOpen in interface io.netty.channel.Channel
      • isActive

        public boolean isActive()
        Specified by:
        isActive in interface io.netty.channel.Channel
      • isWritable

        public boolean isWritable()
        Specified by:
        isWritable in interface io.netty.channel.Channel
      • id

        public io.netty.channel.ChannelId id()
        Specified by:
        id in interface io.netty.channel.Channel
      • eventLoop

        public io.netty.channel.EventLoop eventLoop()
        Specified by:
        eventLoop in interface io.netty.channel.Channel
      • parent

        public io.netty.channel.Channel parent()
        Specified by:
        parent in interface io.netty.channel.Channel
      • isRegistered

        public boolean isRegistered()
        Specified by:
        isRegistered in interface io.netty.channel.Channel
      • localAddress

        public java.net.SocketAddress localAddress()
        Specified by:
        localAddress in interface io.netty.channel.Channel
      • remoteAddress

        public java.net.SocketAddress remoteAddress()
        Specified by:
        remoteAddress in interface io.netty.channel.Channel
      • closeFuture

        public io.netty.channel.ChannelFuture closeFuture()
        Specified by:
        closeFuture in interface io.netty.channel.Channel
      • bytesBeforeUnwritable

        public long bytesBeforeUnwritable()
        Specified by:
        bytesBeforeUnwritable in interface io.netty.channel.Channel
      • bytesBeforeWritable

        public long bytesBeforeWritable()
        Specified by:
        bytesBeforeWritable in interface io.netty.channel.Channel
      • unsafe

        public io.netty.channel.Channel.Unsafe unsafe()
        Specified by:
        unsafe in interface io.netty.channel.Channel
      • pipeline

        public io.netty.channel.ChannelPipeline pipeline()
        Specified by:
        pipeline in interface io.netty.channel.Channel
      • alloc

        public io.netty.buffer.ByteBufAllocator alloc()
        Specified by:
        alloc in interface io.netty.channel.Channel
      • read

        public io.netty.channel.Channel read()
        Specified by:
        read in interface io.netty.channel.Channel
        Specified by:
        read in interface io.netty.channel.ChannelOutboundInvoker
      • flush

        public io.netty.channel.Channel flush()
        Specified by:
        flush in interface io.netty.channel.Channel
        Specified by:
        flush in interface io.netty.channel.ChannelOutboundInvoker
      • bind

        public io.netty.channel.ChannelFuture bind​(java.net.SocketAddress localAddress)
        Specified by:
        bind in interface io.netty.channel.ChannelOutboundInvoker
      • connect

        public io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress)
        Specified by:
        connect in interface io.netty.channel.ChannelOutboundInvoker
      • connect

        public io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress,
                                                      java.net.SocketAddress localAddress)
        Specified by:
        connect in interface io.netty.channel.ChannelOutboundInvoker
      • disconnect

        public io.netty.channel.ChannelFuture disconnect()
        Specified by:
        disconnect in interface io.netty.channel.ChannelOutboundInvoker
      • close

        public io.netty.channel.ChannelFuture close()
        Specified by:
        close in interface io.netty.channel.ChannelOutboundInvoker
      • deregister

        public io.netty.channel.ChannelFuture deregister()
        Specified by:
        deregister in interface io.netty.channel.ChannelOutboundInvoker
      • bind

        public io.netty.channel.ChannelFuture bind​(java.net.SocketAddress localAddress,
                                                   io.netty.channel.ChannelPromise promise)
        Specified by:
        bind in interface io.netty.channel.ChannelOutboundInvoker
      • connect

        public io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress,
                                                      io.netty.channel.ChannelPromise promise)
        Specified by:
        connect in interface io.netty.channel.ChannelOutboundInvoker
      • connect

        public io.netty.channel.ChannelFuture connect​(java.net.SocketAddress remoteAddress,
                                                      java.net.SocketAddress localAddress,
                                                      io.netty.channel.ChannelPromise promise)
        Specified by:
        connect in interface io.netty.channel.ChannelOutboundInvoker
      • disconnect

        public io.netty.channel.ChannelFuture disconnect​(io.netty.channel.ChannelPromise promise)
        Specified by:
        disconnect in interface io.netty.channel.ChannelOutboundInvoker
      • close

        public io.netty.channel.ChannelFuture close​(io.netty.channel.ChannelPromise promise)
        Specified by:
        close in interface io.netty.channel.ChannelOutboundInvoker
      • deregister

        public io.netty.channel.ChannelFuture deregister​(io.netty.channel.ChannelPromise promise)
        Specified by:
        deregister in interface io.netty.channel.ChannelOutboundInvoker
      • write

        public io.netty.channel.ChannelFuture write​(java.lang.Object msg)
        Specified by:
        write in interface io.netty.channel.ChannelOutboundInvoker
      • write

        public io.netty.channel.ChannelFuture write​(java.lang.Object msg,
                                                    io.netty.channel.ChannelPromise promise)
        Specified by:
        write in interface io.netty.channel.ChannelOutboundInvoker
      • writeAndFlush

        public io.netty.channel.ChannelFuture writeAndFlush​(java.lang.Object msg,
                                                            io.netty.channel.ChannelPromise promise)
        Specified by:
        writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker
      • writeAndFlush

        public io.netty.channel.ChannelFuture writeAndFlush​(java.lang.Object msg)
        Specified by:
        writeAndFlush in interface io.netty.channel.ChannelOutboundInvoker
      • newPromise

        public io.netty.channel.ChannelPromise newPromise()
        Specified by:
        newPromise in interface io.netty.channel.ChannelOutboundInvoker
      • newProgressivePromise

        public io.netty.channel.ChannelProgressivePromise newProgressivePromise()
        Specified by:
        newProgressivePromise in interface io.netty.channel.ChannelOutboundInvoker
      • newSucceededFuture

        public io.netty.channel.ChannelFuture newSucceededFuture()
        Specified by:
        newSucceededFuture in interface io.netty.channel.ChannelOutboundInvoker
      • newFailedFuture

        public io.netty.channel.ChannelFuture newFailedFuture​(java.lang.Throwable cause)
        Specified by:
        newFailedFuture in interface io.netty.channel.ChannelOutboundInvoker
      • voidPromise

        public io.netty.channel.ChannelPromise voidPromise()
        Specified by:
        voidPromise in interface io.netty.channel.ChannelOutboundInvoker
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • compareTo

        public int compareTo​(io.netty.channel.Channel o)
        Specified by:
        compareTo in interface java.lang.Comparable<io.netty.channel.Channel>
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • flush0

        protected void flush0​(io.netty.channel.ChannelHandlerContext ctx)
      • write0

        protected io.netty.channel.ChannelFuture write0​(io.netty.channel.ChannelHandlerContext ctx,
                                                        java.lang.Object msg)