From 5129c6a31d1cc1a412d1972c9ee1a6664eb1a402 Mon Sep 17 00:00:00 2001
From: Oleh Dokuka <oleh.dokuka@icloud.com>
Date: Thu, 30 Mar 2023 22:41:02 +0300
Subject: [PATCH] fixes

Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
---
 rsocket-transport-netty/build.gradle                          | 4 ++++
 .../src/main/java/reactor/netty/channel/FluxReceive.java      | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/rsocket-transport-netty/build.gradle b/rsocket-transport-netty/build.gradle
index 0dd02b180..0a6cd8b8a 100644
--- 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
index 53169adc2..5c542ece7 100644
--- 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;