reactive realization observer pattern on java
This project is based on:
- NotifyObservable - notify when event is triggered (not emit data)
- SingleObservable - emit only one object if work after the subscription was successful
- StreamObservable - emit stream data and notify about complete if work after the subscription was successful
Operators:
- map - convert observe object to other object
- flat - make other observable from observe object
- chain - run all observables in chain with order
- merge - observe tuple of two objects from two other observables when their subscription finish successful
- filter - emit only objects who satisfy condition
Observables can convert from\to other type observables + can create chains
see sample
All observables notify about error (with Throwable) if work after the subscription was not successful