Uses of Interface
com.hazelcast.jet.function.Observer
Package
Description
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Serializable and exception-declaring variants of functional interfaces from
java.util.function
.-
Uses of Observer in com.hazelcast.jet
Modifier and TypeMethodDescriptionObservable.addObserver
(Observer<T> observer) Registers anObserver
to thisObservable
. -
Uses of Observer in com.hazelcast.jet.function
Modifier and TypeMethodDescriptionstatic <T> Observer<T>
Observer.of
(ConsumerEx<? super T> onNext) Utility method for building anObserver
only from its data callback, with default behaviour for completion & error.static <T> Observer<T>
Observer.of
(ConsumerEx<? super T> onNext, ConsumerEx<? super Throwable> onError, RunnableEx onComplete) Utility method for building anObserver
from its basic callback components.