Uses of Interface
com.hazelcast.jet.function.Observer
Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.function |
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 Observer Modifier and Type Method Description UUID
Observable. addObserver(Observer<T> observer)
Registers anObserver
to thisObservable
. -
Uses of Observer in com.hazelcast.jet.function
Methods in com.hazelcast.jet.function that return Observer Modifier and Type Method Description static <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.