Uses of Class
org.axonframework.axonserver.connector.util.UpstreamAwareStreamObserver

Packages that use UpstreamAwareStreamObserver

Package	Description
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.command
org.axonframework.axonserver.connector.query

Uses of UpstreamAwareStreamObserver in org.axonframework.axonserver.connector

Method parameters in org.axonframework.axonserver.connector with type arguments of type UpstreamAwareStreamObserver

Modifier and Type	Method and Description
AxonServerConnectionManager.Builder	AxonServerConnectionManager.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<PlatformOutboundInstruction>,io.grpc.stub.StreamObserver<PlatformInboundInstruction>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.

Uses of UpstreamAwareStreamObserver in org.axonframework.axonserver.connector.command

Method parameters in org.axonframework.axonserver.connector.command with type arguments of type UpstreamAwareStreamObserver

Modifier and Type	Method and Description
AxonServerCommandBus.Builder	AxonServerCommandBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<CommandProviderInbound>,io.grpc.stub.StreamObserver<CommandProviderOutbound>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.

Uses of UpstreamAwareStreamObserver in org.axonframework.axonserver.connector.query

Method parameters in org.axonframework.axonserver.connector.query with type arguments of type UpstreamAwareStreamObserver

Modifier and Type	Method and Description
AxonServerQueryBus.Builder	AxonServerQueryBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<QueryProviderInbound>,io.grpc.stub.StreamObserver<QueryProviderOutbound>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.