diff --git a/src/stream_interface.c b/src/stream_interface.c
index 52aa7c4..51f2300 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -764,8 +764,10 @@
 
 	if (!cs)
 		return NULL;
-	if (!(si->wait_list.wait_reason & SUB_CAN_SEND))
+	if (!(si->wait_list.wait_reason & SUB_CAN_SEND)) {
 		si_cs_send(cs);
+		si_cs_wake_cb(cs);
+	}
 	return (NULL);
 }