Class MpscChannelConsumer<E>

All Implemented Interfaces:
ChannelConsumer

public abstract class MpscChannelConsumer<E> extends MpscOffHeapFixedSizeRingBuffer implements ChannelConsumer
Package Scoped: not part of public API.
  • Field Details

    • receiver

      protected final ChannelReceiver<E> receiver
    • pointer

      protected long pointer
  • Constructor Details

    • MpscChannelConsumer

      public MpscChannelConsumer(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)