Uses of Interface
com.hazelcast.jet.function.Observer
Packages that use 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
Methods in com.hazelcast.jet with parameters of type ObserverModifier and TypeMethodDescriptionObservable.addObserver
(Observer<T> observer) Registers anObserver
to thisObservable
. -
Uses of Observer in com.hazelcast.jet.function
Methods in com.hazelcast.jet.function that return ObserverModifier 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.