Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.impl

Interface DisposableReadonlyBuffer<T>

Type Parameters:

T - the type of messages in this buffer

All Superinterfaces:

CloseableReadonlyBuffer<T>

All Known Implementing Classes:

FlowControlledDisposableReadonlyBuffer, RoundRobinMultiReadonlyBuffer

public interface DisposableReadonlyBuffer<T>
extends CloseableReadonlyBuffer<T>

A buffer that can be disposed of from the subscriber's side.

Since:

4.6.0

Author:

Milan Savic, Stefan Dragisic, Allard Buijze

Method Summary

Modifier and Type	Method	Description
void	dispose()	Disposes this buffer from the subscriber's side.

Methods inherited from interface io.axoniq.axonserver.connector.impl.CloseableReadonlyBuffer

capacity, closed, error, isEmpty, onAvailable, poll

Method Detail

dispose

void dispose()

Disposes this buffer from the subscriber's side.