| 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 © 2021 Hazelcast, Inc.. All rights reserved.