diff --git a/include/proto/stream_interface.h b/include/proto/stream_interface.h
index a687b2a..1a70536 100644
--- a/include/proto/stream_interface.h
+++ b/include/proto/stream_interface.h
@@ -396,6 +396,9 @@
 	if (!(si->flags & SI_FL_WANT_PUT))
 		return;
 
+	if (si->state > SI_ST_EST)
+		return;
+
 	si->ops->chk_rcv(si);
 }
 
diff --git a/src/stream_interface.c b/src/stream_interface.c
index ad9ff9e..adbdfa8 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -248,7 +248,7 @@
 		__FUNCTION__,
 		si, si->state, ic->flags, si_oc(si)->flags);
 
-	if (unlikely(si->state != SI_ST_EST || (ic->flags & (CF_SHUTR|CF_DONT_READ))))
+	if (ic->flags & (CF_SHUTR|CF_DONT_READ))
 		return;
 
 	if (!channel_may_recv(ic) || ic->pipe) {
@@ -960,7 +960,7 @@
 {
 	struct channel *ic = si_ic(si);
 
-	if (unlikely(si->state > SI_ST_EST || (ic->flags & CF_SHUTR)))
+	if (ic->flags & CF_SHUTR)
 		return;
 
 	if ((ic->flags & CF_DONT_READ) || !channel_may_recv(ic)) {
@@ -1498,7 +1498,7 @@
 		__FUNCTION__,
 		si, si->state, ic->flags, si_oc(si)->flags);
 
-	if (unlikely(si->state != SI_ST_EST || (ic->flags & (CF_SHUTR|CF_DONT_READ))))
+	if (ic->flags & (CF_SHUTR|CF_DONT_READ))
 		return;
 
 	if (channel_may_recv(ic) && !ic->pipe) {