Implementation of reactive extension support using Java 8