SubscriptionCallback

public interface SubscriptionCallback implements Consumer<T>

Delivers the given subscription update to the read-side.

See also

Functions

Link copied to clipboard
public static SubscriptionCallback forwardingTo(StreamObserver<SubscriptionUpdate> observer)
Creates the callback which forwards to the passed observer.

Inherited functions

Link copied to clipboard
public abstract void accept(T p)
Link copied to clipboard
public Consumer<T> andThen(Consumer<? extends Object> after)