Reactor Pattern implementation for Java