Fixed failing test.

Any server that processes the request in a different thread, should flush explicitly.
ReactiveX · Jul 5, 2014 · 09aec45 · 09aec45
1 parent 45f00a0
commit 09aec45
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/rx-netty-contexts/src/test/java/io/reactivex/netty/contexts/http/ContextPropagationTest.java b/rx-netty-contexts/src/test/java/io/reactivex/netty/contexts/http/ContextPropagationTest.java
@@ -13,6 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package io.reactivex.netty.contexts.http;
 
 import com.netflix.server.context.ContextSerializationException;
@@ -249,7 +250,7 @@ public Observable<Void> handle(HttpServerRequest<ByteBuf> request,
                             @Override
                             public Observable<Void> call(HttpClientResponse<ByteBuf> response) {
                                 serverResponse.setStatus(response.getStatus());
-                                return Observable.empty();
+                                return serverResponse.close(true);
                             }
                         });
             }