From b80cf2ea6066ba66e67e5c2377c5a81fce3272b7 Mon Sep 17 00:00:00 2001
From: Robert Roeser <rroeser@netflix.com>
Date: Wed, 6 Apr 2016 16:50:42 -0700
Subject: [PATCH] request response now returns a response frame with a complete
 flag set

---
 src/main/java/io/reactivesocket/internal/Responder.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/reactivesocket/internal/Responder.java b/src/main/java/io/reactivesocket/internal/Responder.java
index 640f2f06f..57870ea21 100644
--- a/src/main/java/io/reactivesocket/internal/Responder.java
+++ b/src/main/java/io/reactivesocket/internal/Responder.java
@@ -26,6 +26,7 @@
 import io.reactivesocket.exceptions.InvalidSetupException;
 import io.reactivesocket.exceptions.RejectedException;
 import io.reactivesocket.exceptions.SetupException;
+import io.reactivesocket.internal.frame.FrameHeaderFlyweight;
 import io.reactivesocket.internal.frame.SetupFrameFlyweight;
 import io.reactivesocket.internal.rx.EmptyDisposable;
 import io.reactivesocket.internal.rx.EmptySubscription;
@@ -431,7 +432,7 @@ public void onNext(Payload v) {
 									onError(exc);
 								} else {
 									Frame nextCompleteFrame = Frame.Response.from(
-											streamId, FrameType.NEXT_COMPLETE, v);
+											streamId, FrameType.RESPONSE, v.getMetadata(), v.getData(), FrameHeaderFlyweight.FLAGS_RESPONSE_C);
 									child.onNext(nextCompleteFrame);
 								}
 							}