Undertow + CompletedFuture/RxJava

Question

public class HelloWorldServer { 

    public static void main(final String[] args) { 
     Undertow server = Undertow.builder() 
       .addHttpListener(8080, "localhost") 
       .setHandler(new HttpHandler() { 
        @Override 
        public void handleRequest(final HttpServerExchange exchange) throws Exception { 
         exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain"); 
         exchange.getResponseSender().send("Hello World"); 
        } 
       }).build(); 
     server.start(); 
    } 
} 

Это приветственное приложение мира с использованием подноса. Может ли кто-нибудь предоставить пример с Undertow + CompletableFuture или RxJava? Я искал, но безуспешно.

Answer 1

Вот прибойный привет мир с RxJava 2:

public static void main(final String[] args) { 
    Observable<HttpServerExchange> exchangeObservable = Observable.create(observableEmitter -> { 
     Undertow server = Undertow.builder() 
       .addHttpListener(8080, "localhost") 
       .setHandler(new HttpHandler() { 
        @Override 
        public void handleRequest(final HttpServerExchange exchange) throws Exception { 
         observableEmitter.onNext(exchange); 
        } 
       }).build(); 
     server.start(); 
     observableEmitter.setCancellable(() -> server.stop()); 
    }); 

    exchangeObservable.subscribe(exchange -> { 
     exchange.getResponseHeaders().put(Headers.CONTENT_TYPE, "text/plain"); 
     exchange.getResponseSender().send("Hello World"); 
    }); 
} 

Это лишь простейший пример, то привет мир Undertow + RxJava, который не принимает во внимание управление потоками среди других вещей. Я использовал Observable.create() для обертывания HttpHandler и его обратного вызова к Observable. Этот Observable представляет поток входящего запроса, который вы будете потреблять (часть exchangeObservable.subscribe()) для обработки запросов.

RxJava изменится только грамматику от обратного вызова для наблюдаемой модели, а также предлагает хороший набор операторов для борьбы с ними: http://reactivex.io/documentation/operators.html