EventObserver

public interface EventObserver<E extends EventMessage> implements EventConsumer<E>

Adapts gRPC streaming API to EventConsumer by passing the received Event to the accept method.

<E>

the type of the event messages received by this observer

Functions

public void onNext(Event value)

public abstract void accept(T p, U p1)

public BiConsumer<T, U> andThen(BiConsumer<? extends Object, ? extends Object> after)

public static EventConsumer<E> from<E extends EventMessage>(Consumer<E> consumer)

Converts the passed consumer of the event message to EventConsumer.