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;