1.2.2 release

This is a bug fix release, thanks to @iSerge.

1.2.1 release

• Added exec() and flatMap() methods to Either.
• Added exec() methods to tuples.
• Added EventStream.watch(subscriber, monitor) method as a convenient shortcut to subscribe(subscriber).and(monitor(monitor)).
• Deprecated EitherEventStream because of questionable utility.
• Added EventStream.mapToBi() and mapToTri() that return a BiEventStream and TriEventStream, respectively.

1.2.0 release

New in this release:

• Error-reporting mechanism.
• Variants of Subscription.multi(...) that "subscribe" to arbitrary elements.
• Subscription.dynamic(ObservableSet<T>, Function<T,Subscription>) to dynamically subscribe to elements of an observable set.
• EventStreams.sizeOf(...) factory methods to emit the current size of an observable collection.
• Added Connectable interface for objects that are capable of lazily subscribing to event streams.
  • Added ConnectableEventSource, an event source that lazily subscribes to any number of event streams, i.e. it is subscribed to its input streams only when it itself has at least one subscriber.

1.1.3 release

New in this release:

• Added EventStream.feedTo(WritableValue) method.
• Added accumulate(...) operators.
• Added toStateStream() method to the state machine builder.
• Added Subscription.multi(ObservableSet, T -> Subscription) method to dynamically subscribe to elements of an observable set.
• Added a version of merge that merges all event streams in an observable set.
• Added more convenient methods on tuples, Either and EitherEventStream.
• Added EventStream.test(Predicate) operator.
• Added Try type.

1.1.2 release

New in this release:

• Added EitherEventStream, a specialized stream for events of type Either<L, R>.
• Added supply(U) combinator to replace the emitted event with a constant value.
• Added EventStreams.eventsOf(Scene, EventType) factory method to create a stream of events on a Scene. This complements the EventStreams.eventsOf(Node, EventType) method present in ReactFX from the start.

1.1.1 release

This is a minor release that only adds the distinct() combinator (thanks to @Sinicyn).

1.1.0 release

This release contains some backwards incompatible changes.

This is also the first release with a third-party contribution. Thanks, @Sinicyn!

Changes in this release:

• Streams returned from reduceSuccessions and await now indicate whether there is a pending event. This change is source compatible, but not binary compatible with the previous release, because the return of those methods has changed.
• Added cast(Class<U>) combinator to conveniently downcast the events emitted by the stream.
• Added emitOnEach(impulse) and repeatOn(impulse) combinators.
• Added EventStreams.nonNullValuesOf(ObservableValue<T>) factory method.
• Sink was renamed to EventSink.
• Bi- and tri-valued EventStreams, EventSinks and EventSources are provided for convenience: BiEventStream, BiEventSink, BiEventSource, TriEventStream, TriEventSink, TriEventSource.
• zip and combine now return multi-valued streams directly. This is a backwards-incompatible change.
• Added a convenience flatMapOpt combinator.
• Added Either<A, B> type and or combinator.
• Added methods to connect an EventSink to an EventStream: EventStream.feedTo(EventSink) and EventSink.feedFrom(EventStream).
• Exposed internally used FxTimer as public API.
• Added EventStreams.ticks(interval) factory method to create a stream of periodic ticks.
• A number of deprecated APIs were removed.

1.0.2 release

• Added newSubscriber hook to EventStreamBase to be called for each new subscriber.
• valuesOf() stream now re-emits the current value for each new subscriber.
• Added flatMap combinator.
• Support for out of order unblocking of InhiBeans and Indicator.
• Added reduce and toArray methods to ListHelper.

1.0.1 release

• Added the Guardian interface.
• Added the EventStream.guardedBy(Guardian...) method.
• Added asynchronously mapped streams.
• Added a convenience successionEnds method.
• Added the supply "combinator".
• Added the pin method to keep lazily bound streams bound.
• Added the hook method useful for debugging.
• Added state machine as a generalized stream combinator.
• Added a convenient implementation of tuples.
• Added an inhibitory ObservableList wrapper to InhiBeans.

1.0.0 release

First release.