Integration of reactive extensions with Hazelcast distributed data structures.