Java implementation of the .NET Reactive Extensions.