fixes

Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
rsocket · Mar 30, 2023 · 5129c6a · 5129c6a
1 parent 5050581
commit 5129c6a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/rsocket-transport-netty/build.gradle b/rsocket-transport-netty/build.gradle
@@ -52,4 +52,8 @@ jar {
     }
 }
 
+test {
+    minHeapSize = "512m"
+}
+
 description = 'Reactor Netty RSocket transport implementations (TCP, Websocket)'
diff --git a/rsocket-transport-netty/src/main/java/reactor/netty/channel/FluxReceive.java b/rsocket-transport-netty/src/main/java/reactor/netty/channel/FluxReceive.java
@@ -166,7 +166,7 @@ final void startReceiver(CoreSubscriber<? super Object> s) {
 
       s.onSubscribe(this);
     } else {
-      if (inboundDone && getPending() == 0) {
+      if ((inboundDone && getPending() == 0) || isCancelled()) {
         if (inboundError != null) {
           Operators.error(s, inboundError);
           return;