Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event.impl

Class BufferedAggregateEventStream

java.lang.Object

io.axoniq.axonserver.connector.impl.FlowControlledStream<T,R>

io.axoniq.axonserver.connector.impl.FlowControlledBuffer<Event,GetAggregateEventsRequest>

io.axoniq.axonserver.connector.event.impl.BufferedAggregateEventStream

All Implemented Interfaces:

AggregateEventStream, io.grpc.stub.ClientResponseObserver<GetAggregateEventsRequest,Event>, io.grpc.stub.StreamObserver<Event>

public class BufferedAggregateEventStream
extends FlowControlledBuffer<Event,GetAggregateEventsRequest>
implements AggregateEventStream

Buffering implementation of the AggregateEventStream used for Event Sourced Aggregates.

Constructor Summary

Constructors

Constructor	Description
BufferedAggregateEventStream()	Constructs a BufferedAggregateEventStream with a buffer size of 512 and a refillBatch of 16.
BufferedAggregateEventStream(int bufferSize, int refillBatch)	Constructs a BufferedAggregateEventStream with the given bufferSize.

Method Summary

Modifier and Type	Method	Description
protected GetAggregateEventsRequest	buildFlowControlMessage(FlowControl flowControl)	Build a flow control message of type OUT based on the given flowControl.
void	cancel()	Close this stream for further reading, notifying the provider of Events to stop streaming them.
boolean	hasNext()	Indicates whether a new event is available.
Event	next()	Returns the next available event, possibly blocking until one becomes available for reading.
protected Event	terminalMessage()	Builds a terminal message of type T specifying when the this stream is closed.

Methods inherited from class io.axoniq.axonserver.connector.impl.FlowControlledBuffer

beforeStart, close, getErrorResult, isClosed, onCompleted, onError, onNext, peek, take, tryTake, tryTake, tryTake, tryTakeNow

Methods inherited from class io.axoniq.axonserver.connector.impl.FlowControlledStream

buildInitialFlowControlMessage, enableFlowControl, markConsumed, outboundStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.axoniq.axonserver.connector.event.AggregateEventStream

asStream

Constructor Detail

BufferedAggregateEventStream

public BufferedAggregateEventStream()

Constructs a BufferedAggregateEventStream with a buffer size of 512 and a refillBatch of 16.

BufferedAggregateEventStream

public BufferedAggregateEventStream(int bufferSize,
                                    int refillBatch)

Constructs a BufferedAggregateEventStream with the given bufferSize.

Parameters:

bufferSize - the buffer size of the aggregate event stream

Method Detail

next

public Event next()
           throws InterruptedException

Description copied from interface: AggregateEventStream

Returns the next available event, possibly blocking until one becomes available for reading.

Specified by:

next in interface AggregateEventStream

Returns:

the next event

Throws:

InterruptedException - if the current thread was interrupted while waiting for an event to become available

See Also:

to verify availability of events

hasNext

public boolean hasNext()

Description copied from interface: AggregateEventStream

Indicates whether a new event is available. This method may block while waiting for a confirmation if an event is available for reading.

Specified by:

hasNext in interface AggregateEventStream

Returns:

true if a message is available, or false if the stream has reached the end

cancel

public void cancel()

Description copied from interface: AggregateEventStream

Close this stream for further reading, notifying the provider of Events to stop streaming them. Any event already emitted by the sender may still be consumed.

Note that after calling cancel, AggregateEventStream.hasNext() may throw a StreamClosedException if the cancellation caused the stream to close before the last message was received.

Specified by:

cancel in interface AggregateEventStream

buildFlowControlMessage

protected GetAggregateEventsRequest buildFlowControlMessage(FlowControl flowControl)

Description copied from class: FlowControlledStream

Build a flow control message of type OUT based on the given flowControl.

Specified by:

buildFlowControlMessage in class FlowControlledStream<Event,GetAggregateEventsRequest>

Parameters:

flowControl - the FlowControl message used to base this implementation's flow control message on

Returns:

the message used by this implementation to request new entries of type IN

terminalMessage

protected Event terminalMessage()

Description copied from class: FlowControlledBuffer

Builds a terminal message of type T specifying when the this stream is closed.

Specified by:

terminalMessage in class FlowControlledBuffer<Event,GetAggregateEventsRequest>

Returns:

a terminal message of type T specifying when the this stream is closed