Package org.drasyl.channel.embedded

Class UserEventAwareEmbeddedChannel

java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.embedded.EmbeddedChannel
org.drasyl.channel.embedded.UserEventAwareEmbeddedChannel
All Implemented Interfaces:
io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>
public class UserEventAwareEmbeddedChannel extends io.netty.channel.embedded.EmbeddedChannel
A EmbeddedChannel that record all received user events.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

    io.netty.channel.AbstractChannel.AbstractUnsafe

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

    io.netty.channel.Channel.Unsafe

  • Constructor Summary

    Constructors
    Constructor
    Description
    UserEventAwareEmbeddedChannel(io.netty.channel.ChannelHandler... handlers)
     
    UserEventAwareEmbeddedChannel(SocketAddress localAddress, io.netty.channel.ChannelHandler... handlers)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected SocketAddress
    localAddress0()
     
    <T> T
    readEvent()
    Return received user events from this Channel
    Queue<Object>
    userEvents()
    Returns the Queue which holds all the user events that were received by this Channel.

    Methods inherited from class io.netty.channel.embedded.EmbeddedChannel

    advanceTimeBy, checkException, close, close, config, disconnect, disconnect, doBeginRead, doBind, doClose, doDisconnect, doRegister, doWrite, ensureOpen, finish, finishAndReleaseAll, flushInbound, flushOutbound, freezeTime, handleInboundMessage, handleOutboundMessage, hasPendingTasks, inboundMessages, isActive, isCompatible, isOpen, lastInboundBuffer, lastOutboundBuffer, metadata, newChannelPipeline, newUnsafe, outboundMessages, readInbound, readOutbound, register, releaseInbound, releaseOutbound, remoteAddress0, runPendingTasks, runScheduledPendingTasks, unfreezeTime, unsafe, writeInbound, writeOneInbound, writeOneInbound, writeOneOutbound, writeOneOutbound, writeOutbound

    Methods inherited from class io.netty.channel.AbstractChannel

    alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, doDeregister, doShutdownOutput, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush

    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

  • Constructor Details

    • UserEventAwareEmbeddedChannel

      public UserEventAwareEmbeddedChannel(SocketAddress localAddress, io.netty.channel.ChannelHandler... handlers)

    • UserEventAwareEmbeddedChannel

      public UserEventAwareEmbeddedChannel(io.netty.channel.ChannelHandler... handlers)

  • Method Details

    • localAddress0

      protected SocketAddress localAddress0()
      Overrides:
      localAddress0 in class io.netty.channel.embedded.EmbeddedChannel

    • userEvents

      public Queue<Object> userEvents()
      Returns the Queue which holds all the user events that were received by this Channel.

    • readEvent

      public <T> T readEvent()
      Return received user events from this Channel