io.spine.client

Interface EventObserver<E extends io.spine.base.EventMessage>

Type Parameters:

E - the type of the event messages received by this observer

All Superinterfaces:

EventConsumer<E>, io.grpc.stub.StreamObserver<io.spine.core.Event>

public interface EventObserver<E extends io.spine.base.EventMessage>
extends io.grpc.stub.StreamObserver<io.spine.core.Event>, EventConsumer<E>

Adapts gRPC streaming API to EventConsumer by passing the received Event to the BiConsumer.accept(Object, Object) method.

Method Summary

Modifier and Type	Method and Description
default void	onNext(io.spine.core.Event value)

Methods inherited from interface io.grpc.stub.StreamObserver

onCompleted, onError

Methods inherited from interface io.spine.client.EventConsumer

from

Methods inherited from interface java.util.function.BiConsumer

accept, andThen

Method Detail

onNext

default void onNext(io.spine.core.Event value)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<io.spine.core.Event>