cyclops_SimpleReact.java

    public void initiateOutboundSyncReactor(ConcurrentLinkedQueue<Tuple3<String, String, HttpMethod>> q) {

        simpleReact.
                from(q.stream().map(it -> syncMaker.call(q.poll()))).
                then(resp -> syncMaker.handleSyncResponse(resp)).
                onFail(e -> syncMaker.handleError(e, e.getValue()));

    }

    public void initiateOutboundAsyncReactor(ConcurrentLinkedQueue<Tuple3<String, String, HttpMethod>> q) {

        simpleReact.
                fromStream(q.stream().map(it -> FutureConverter.toCompletableFuture(asyncMaker.call(q.peek())))).
                then(resp -> asyncMaker.handleAsyncResponse(resp)).
                onFail(e -> asyncMaker.handleError(e, e.getValue()));

    }