Uses of Interface
org.agrona.ExpandableRingBuffer.MessageConsumer
Packages that use ExpandableRingBuffer.MessageConsumer
Package
Description
Data structures and utilities useful for building high-performance Java applications.
-
Uses of ExpandableRingBuffer.MessageConsumer in org.agrona
Methods in org.agrona with parameters of type ExpandableRingBuffer.MessageConsumerModifier and TypeMethodDescriptionintExpandableRingBuffer.consume(ExpandableRingBuffer.MessageConsumer messageConsumer, int messageLimit) Consume messages up to a limit and pass them to theExpandableRingBuffer.MessageConsumer.intExpandableRingBuffer.forEach(int headOffset, ExpandableRingBuffer.MessageConsumer messageConsumer, int limit) Iterate encoded contents and pass messages to theExpandableRingBuffer.MessageConsumerwhich can stop by returning false.intExpandableRingBuffer.forEach(ExpandableRingBuffer.MessageConsumer messageConsumer, int limit) Iterate encoded contents and pass messages to theExpandableRingBuffer.MessageConsumerwhich can stop by returning false.