Uses of Interface
io.axoniq.axonserver.connector.FlowControl
-
Packages that use FlowControl Package Description io.axoniq.axonserver.connector.impl io.axoniq.axonserver.connector.impl.buffer io.axoniq.axonserver.connector.query -
-
Uses of FlowControl in io.axoniq.axonserver.connector.impl
Classes in io.axoniq.axonserver.connector.impl that implement FlowControl Modifier and Type Class Description classFlowControlledReplyChannelWriter<T>AFlowControlimplementation that onFlowControlledReplyChannelWriter.request(long)retrieves messages from thebuffer.classNoopFlowControlNOOP implementation ofFlowControl. -
Uses of FlowControl in io.axoniq.axonserver.connector.impl.buffer
Constructors in io.axoniq.axonserver.connector.impl.buffer with parameters of type FlowControl Constructor Description FlowControlledDisposableReadonlyBuffer(FlowControl flowControl, CloseableReadonlyBuffer<T> buffer)Instantiates this buffer with the givenflowControlandbuffer. -
Uses of FlowControl in io.axoniq.axonserver.connector.query
Methods in io.axoniq.axonserver.connector.query that return FlowControl Modifier and Type Method Description default FlowControlQueryHandler. stream(QueryRequest query, ReplyChannel<QueryResponse> responseHandler)Handle the givenquery, using the givenresponseHandlerto send the response(s).
-