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 TypeMethodDescriptionint
ExpandableRingBuffer.consume
(ExpandableRingBuffer.MessageConsumer messageConsumer, int messageLimit) Consume messages up to a limit and pass them to theExpandableRingBuffer.MessageConsumer
.int
ExpandableRingBuffer.forEach
(int headOffset, ExpandableRingBuffer.MessageConsumer messageConsumer, int limit) Iterate encoded contents and pass messages to theExpandableRingBuffer.MessageConsumer
which can stop by returning false.int
ExpandableRingBuffer.forEach
(ExpandableRingBuffer.MessageConsumer messageConsumer, int limit) Iterate encoded contents and pass messages to theExpandableRingBuffer.MessageConsumer
which can stop by returning false.