[resteasy-commits] [resteasy/Resteasy] 6e24e4: [RESTEASY-1701][RESTEASY-1680] Async stream provid...

Branch: refs/heads/master Home: https://github.com/resteasy/Resteasy Commit: 6e24e40f34c58be364eba8ca5ebfc3530badd53b https://github.com/resteasy/Resteasy/commit/6e24e40f34c58be364eba8ca5ebfc... Author: Alessio Soldano <soldano.servizi(a)email.it&gt; Date: 2017-09-26 (Tue, 26 Sep 2017) Changed paths: M jboss-modules/build.xml M jboss-modules/pom.xml M jboss-modules/src/main/resources/modules/org/jboss/resteasy/resteasy-jaxrs/main/module.xml A jboss-modules/src/main/resources/modules/org/reactivestreams/main/module.xml M resteasy-dependencies-bom/pom.xml M resteasy-jaxrs/pom.xml A resteasy-jaxrs/src/main/java/org/jboss/resteasy/annotations/Stream.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/AbstractAsynchronousResponse.java A resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/AsyncResponseConsumer.java R resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/CompletionStageResponseConsumer.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/ResourceMethodInvoker.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/ServerResponseWriter.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/SynchronousExecutionContext.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/core/ThreadLocalResteasyProviderFactory.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/mock/MockHttpResponse.java A resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/ReactiveStreamProvider.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseEventInputImpl.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseEventOutputImpl.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/providers/sse/SseEventProvider.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/server/servlet/HttpServletResponseWrapper.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/plugins/server/servlet/Servlet3AsyncHttpRequest.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/resteasy_jaxrs/i18n/Messages.java A resteasy-jaxrs/src/main/java/org/jboss/resteasy/spi/AsyncStreamProvider.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/spi/HttpResponse.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/spi/ResteasyAsynchronousResponse.java M resteasy-jaxrs/src/main/java/org/jboss/resteasy/spi/ResteasyProviderFactory.java M resteasy-jaxrs/src/main/resources/META-INF/services/javax.ws.rs.ext.Providers M server-adapters/resteasy-jdk-http/src/main/java/org/jboss/resteasy/plugins/server/sun/http/HttpServerResponse.java M server-adapters/resteasy-netty/src/main/java/org/jboss/resteasy/plugins/server/netty/NettyHttpResponse.java M server-adapters/resteasy-netty4/src/main/java/org/jboss/resteasy/plugins/server/netty/NettyHttpRequest.java M server-adapters/resteasy-netty4/src/main/java/org/jboss/resteasy/plugins/server/netty/NettyHttpResponse.java M server-adapters/resteasy-vertx/src/main/java/org/jboss/resteasy/plugins/server/vertx/VertxHttpRequest.java M server-adapters/resteasy-vertx/src/main/java/org/jboss/resteasy/plugins/server/vertx/VertxHttpResponse.java M testsuite/integration-tests/pom.xml A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/providers/sse/EscapingSseResource.java M testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/providers/sse/SseApplication.java M testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/providers/sse/SseResource.java M testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/providers/sse/SseTest.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/AnotherPublisherResponseTest.java M testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/CompletionStageResponseTest.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/PublisherResponseTest.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/SingleProvider.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/resource/AsyncResponseCallback.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/resource/AsyncResponseException.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/resource/AsyncResponseExceptionMapper.java M testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/resource/CompletionStageResponseResource.java A testsuite/integration-tests/src/test/java/org/jboss/resteasy/test/response/resource/PublisherResponseResource.java Log Message: ----------- [RESTEASY-1701][RESTEASY-1680] Async stream provider / SSE extensions (#1288) * Added dependency to reactive streams * Added support for AsyncStreamProvider * ServerResponseWriter: new option to write response without headers, extracted method for reuse * Unified CompletionStage/AsyncStream consumers, support both, inclusing Sse, stream, collect modes * Sse reader: do not add extra LF at the end * Added tests for streams * Test that Sse output is what we receive (LF fix) * Write SSE by line chunks as per spec * Test SSE line chunks * Test rx2 Single provider * Remove servlet dependency for async * Make sure we only send SSE if the client accepts it * Remove servlet-isms from SSE * Make sure async callbacks are called for CompletionStage/Publisher * Removed unused test class * Fixed merge issue with SseEventProvider * Streaming SSE: make sure we don't request the next one before we've sent the previous one * Delay onComplete until we're done sending messages * Adding test for the onComplete issue * Improving SSE tests * Return correct future in sink.send * Fixing minor import issues