diff --git a/src/main/stream.c b/src/main/stream.c
index d04e9dd..fd94eab 100644
--- a/src/main/stream.c
+++ b/src/main/stream.c
@@ -85,6 +85,7 @@ void li_stream_connect(liStream *source, liStream *dest) {
 	/* streams must be "valid" */
 	assert(source->refcount > 0 && dest->refcount > 0);
 
+	assert(NULL == source->dest && NULL == dest->source);
 	if (NULL != source->dest || NULL != dest->source) {
 		g_error("Can't connect already connected streams");
 	}
diff --git a/src/modules/fastcgi_stream.c b/src/modules/fastcgi_stream.c
index f20a9cd..4bf41c7 100644
--- a/src/modules/fastcgi_stream.c
+++ b/src/modules/fastcgi_stream.c
@@ -238,9 +238,6 @@ static void fastcgi_check_put(liFastCGIBackendContext *ctx) {
 	li_stream_disconnect(&ctx->fcgi_out);
 	li_stream_disconnect_dest(&ctx->fcgi_in);
 
-	assert(2 == ctx->fcgi_in.refcount);
-	assert(2 == ctx->fcgi_out.refcount);
-
 	ctx->is_active = FALSE;
 
 	li_stream_set_cqlimit(NULL, &ctx->fcgi_in, NULL);