Undertow + CompletableFuture/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(); 
    } 
} 

Il est bon application du monde utilisant Undowow. Quelqu'un peut-il donner un exemple avec Undertow + CompletableFuture ou RxJava? J'ai cherché mais sans succès.

Answer 1

Voici le undertow Bonjour tout le monde avec 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"); 
    }); 
} 

Ceci est juste un exemple simpliste, le monde bonjour Undertow + RxJava, qui ne prend pas en compte la gestion des threads entre autres choses. J'ai utilisé Observable.create() pour envelopper le HttpHandler et son rappel à un Observable. Ce Observable représente le flux de la requête entrante que vous allez consommer (la partie exchangeObservable.subscribe()) pour gérer les demandes.

RxJava ne changera la grammaire de rappel à motif observable, plus offrant un bon ensemble d'opérateurs de les traiter: http://reactivex.io/documentation/operators.html