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 anObserverto 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 anObserveronly 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 anObserverfrom its basic callback components.