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 . |
Modifier and Type | Method and Description |
---|---|
UUID |
Observable.addObserver(Observer<T> observer)
Registers an
Observer to this Observable . |
Modifier and Type | Method and Description |
---|---|
static <T> Observer<T> |
Observer.of(ConsumerEx<? super T> onNext)
Utility method for building an
Observer 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 an
Observer from its basic
callback components. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.