public final class SubscriptionService
extends io.spine.client.grpc.SubscriptionServiceGrpc.SubscriptionServiceImplBase
implements io.spine.logging.Logging
SubscriptionService
provides an asynchronous way to fetch read-side state
from the server.
For synchronous read-side updates please see QueryService
.
Modifier and Type | Class and Description |
---|---|
static class |
SubscriptionService.Builder
The builder for the
SubscriptionService . |
Modifier and Type | Method and Description |
---|---|
void |
activate(io.spine.client.Subscription subscription,
io.grpc.stub.StreamObserver<io.spine.client.SubscriptionUpdate> observer) |
void |
cancel(io.spine.client.Subscription subscription,
io.grpc.stub.StreamObserver<io.spine.core.Response> responseObserver) |
static SubscriptionService.Builder |
newBuilder() |
void |
subscribe(io.spine.client.Topic topic,
io.grpc.stub.StreamObserver<io.spine.client.Subscription> responseObserver) |
static SubscriptionService |
withSingle(BoundedContext context)
Builds the service with a single Bounded Context.
|
bindService
public static SubscriptionService.Builder newBuilder()
public static SubscriptionService withSingle(BoundedContext context)
public void subscribe(io.spine.client.Topic topic, io.grpc.stub.StreamObserver<io.spine.client.Subscription> responseObserver)
subscribe
in class io.spine.client.grpc.SubscriptionServiceGrpc.SubscriptionServiceImplBase
public void activate(io.spine.client.Subscription subscription, io.grpc.stub.StreamObserver<io.spine.client.SubscriptionUpdate> observer)
activate
in class io.spine.client.grpc.SubscriptionServiceGrpc.SubscriptionServiceImplBase
public void cancel(io.spine.client.Subscription subscription, io.grpc.stub.StreamObserver<io.spine.core.Response> responseObserver)
cancel
in class io.spine.client.grpc.SubscriptionServiceGrpc.SubscriptionServiceImplBase