From eb22a8eb1dd2225c6cc786fdd7b2190d7f1fcd0c Mon Sep 17 00:00:00 2001
From: segabriel <sergiy.gabriel@jivygroup.com>
Date: Wed, 25 Jul 2018 22:53:43 +0300
Subject: [PATCH] Fixed sending complete signal for mono.empty()

---
 rsocket-core/src/main/java/io/rsocket/RSocketServer.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/rsocket-core/src/main/java/io/rsocket/RSocketServer.java b/rsocket-core/src/main/java/io/rsocket/RSocketServer.java
index 2706ecf5e..eb00b6e3d 100644
--- a/rsocket-core/src/main/java/io/rsocket/RSocketServer.java
+++ b/rsocket-core/src/main/java/io/rsocket/RSocketServer.java
@@ -302,6 +302,7 @@ private void handleRequestResponse(int streamId, Mono<Payload> response) {
               payload.release();
               return frame;
             })
+        .switchIfEmpty(Mono.fromCallable(() -> Frame.PayloadFrame.from(streamId, FrameType.COMPLETE)))
         .doFinally(signalType -> sendingSubscriptions.remove(streamId))
         .subscribe(sendProcessor::onNext, t -> handleError(streamId, t));
   }