Uses of Interface
io.axoniq.axonserver.connector.ResultStream

Packages that use ResultStream

Package	Description
io.axoniq.axonserver.connector
io.axoniq.axonserver.connector.admin
io.axoniq.axonserver.connector.admin.impl
io.axoniq.axonserver.connector.event
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.query
io.axoniq.axonserver.connector.query.impl

Uses of ResultStream in io.axoniq.axonserver.connector

Constructor parameters in io.axoniq.axonserver.connector with type arguments of type ResultStream

Constructor	Description
ResultStreamPublisher(Supplier<ResultStream<M>> resultStreamSupplier)	Constructs an instance based on the specifier supplier of underlying ResultStream.

Uses of ResultStream in io.axoniq.axonserver.connector.admin

Methods in io.axoniq.axonserver.connector.admin that return ResultStream

Modifier and Type	Method	Description
ResultStream<EventProcessor>	AdminChannel.eventProcessors()	Returns all the event processor registered to AxonServer.
ResultStream<EventProcessor>	AdminChannel.eventProcessorsByComponent(String component)	Returns all the event processor registered by the specified application.
ResultStream<ContextUpdate>	AdminChannel.subscribeToContextUpdates()	Subscribes and listens to context updates from Axon Server, like when a context is created or deleted.

Uses of ResultStream in io.axoniq.axonserver.connector.admin.impl

Methods in io.axoniq.axonserver.connector.admin.impl that return ResultStream

Modifier and Type	Method	Description
ResultStream<EventProcessor>	AdminChannelImpl.eventProcessors()
ResultStream<EventProcessor>	AdminChannelImpl.eventProcessorsByComponent(String component)
ResultStream<ContextUpdate>	AdminChannelImpl.subscribeToContextUpdates()

Uses of ResultStream in io.axoniq.axonserver.connector.event

Subinterfaces of ResultStream in io.axoniq.axonserver.connector.event

Modifier and Type	Interface	Description
interface	EventStream	Represents a stream of Events.
interface	PersistentStreamSegment	An event stream producing events for one segment of a persistent stream.

Methods in io.axoniq.axonserver.connector.event that return ResultStream

Modifier and Type	Method	Description
ResultStream<ListSnapshotsResponse>	SnapshotChannel.listSnapshots(ListSnapshotsRequest request)	Lists snapshots for a given key within a specified sequence range.
default ResultStream<EventQueryResultEntry>	EventChannel.queryEvents(String queryExpression, boolean liveStream)	Queries the Event Store for events using given queryExpression.
default ResultStream<EventQueryResultEntry>	EventChannel.queryEvents(String queryExpression, boolean liveStream, String contextName)	Queries the Event Store for events using given queryExpression.
default ResultStream<EventQueryResultEntry>	EventChannel.querySnapshotEvents(String queryExpression, boolean liveStream)	Queries the Event Store for snapshot events using given queryExpression.
default ResultStream<EventQueryResultEntry>	EventChannel.querySnapshotEvents(String queryExpression, boolean liveStream, String contextName)	Queries the Event Store for snapshot events using given queryExpression.
ResultStream<SourceEventsResponse>	DcbEventChannel.source(SourceEventsRequest request)	Provides a finite stream of events used to eventsource a model.
default ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of 64 events.
default ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request, int bufferSize)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of bufferSize.
ResultStream<StreamEventsResponse>	DcbEventChannel.stream(StreamEventsRequest request, int bufferSize, int refillBatch)	Opens an infinite stream of events, for sequentially consuming events from Axon Server, using the given request and keeping a local buffer of bufferSize, which is refilled after consuming refillBatch events.

Uses of ResultStream in io.axoniq.axonserver.connector.event.impl

Classes in io.axoniq.axonserver.connector.event.impl that implement ResultStream

Modifier and Type	Class	Description
class	BufferedEventStream	Buffering implementation of the EventStream used for Event processing.
class	BufferedPersistentStreamSegment	Implementation of the PersistentStreamSegment.

Methods in io.axoniq.axonserver.connector.event.impl that return ResultStream

Modifier and Type	Method	Description
ResultStream<ListSnapshotsResponse>	SnapshotChannelImpl.listSnapshots(ListSnapshotsRequest request)
ResultStream<EventQueryResultEntry>	EventChannelImpl.queryEvents(String queryExpression, boolean liveStream, String contextName)
ResultStream<EventQueryResultEntry>	EventChannelImpl.querySnapshotEvents(String queryExpression, boolean liveStream, String contextName)
ResultStream<SourceEventsResponse>	DcbEventChannelImpl.source(SourceEventsRequest request)
ResultStream<StreamEventsResponse>	DcbEventChannelImpl.stream(StreamEventsRequest request, int bufferSize, int refillBatch)

Uses of ResultStream in io.axoniq.axonserver.connector.impl

Classes in io.axoniq.axonserver.connector.impl that implement ResultStream

Modifier and Type	Class	Description
class	AbstractBufferedStream<T,R>	An abstract FlowControlledBuffer and ResultStream implementation, used to provide a buffered stream of results of T when receiving a request of type R.

Uses of ResultStream in io.axoniq.axonserver.connector.query

Methods in io.axoniq.axonserver.connector.query that return ResultStream

Modifier and Type	Method	Description
ResultStream<QueryResponse>	SubscriptionQueryResult.initialResults()	Returns a ResultStream that represent the initial result of the subscription query.
ResultStream<QueryResponse>	QueryChannel.query(QueryRequest query)	Sends the given query to AxonServer for routing to the appropriate handlers.
ResultStream<QueryUpdate>	SubscriptionQueryResult.updates()	Returns the stream of updates to the queried projection.

Uses of ResultStream in io.axoniq.axonserver.connector.query.impl

Classes in io.axoniq.axonserver.connector.query.impl that implement ResultStream

Modifier and Type	Class	Description
class	SubscriptionQueryUpdateBuffer	Buffer for SubscriptionQuery updates.

Methods in io.axoniq.axonserver.connector.query.impl that return ResultStream

Modifier and Type	Method	Description
ResultStream<QueryResponse>	SubscriptionQueryStream.initialStream()	Returns the ResultStream buffering the initial results to this subscription query.
ResultStream<QueryResponse>	QueryChannelImpl.query(QueryRequest query)
ResultStream<QueryUpdate>	SubscriptionQueryStream.updatesBuffer()	Returns the ResultStream buffering the QueryUpdates to this subscription query.

Constructor parameters in io.axoniq.axonserver.connector.query.impl with type arguments of type ResultStream

Constructor	Description
SubscriptionQueryStream(String subscriptionQueryId, CompletableFuture<QueryResponse> initialResultFuture, String clientId, Supplier<ResultStream<QueryResponse>> initialResultSupplier, int bufferSize, int fetchSize)	Instantiates a SubscriptionQueryStream to stream SubscriptionQuery results.