diff --git a/src/lib_ccx/general_loop.c b/src/lib_ccx/general_loop.c
index b9003a62..75d35792 100644
--- a/src/lib_ccx/general_loop.c
+++ b/src/lib_ccx/general_loop.c
@@ -539,6 +539,8 @@ void raw_loop (struct lib_ccx_ctx *ctx)
 
 	do
 	{
+		if (terminate_asap)
+			break;
 
 		ret = general_getmoredata(ctx, &data);
 		if(ret == CCX_EOF)
@@ -808,7 +810,8 @@ void general_loop(struct lib_ccx_ctx *ctx)
 	end_of_file = 0;
 	while (!end_of_file && is_decoder_processed_enough(ctx) == CCX_FALSE)
 	{
-
+		if (terminate_asap)
+			break;
 		// GET MORE DATA IN BUFFER
 		position_sanity_check(ctx->demux_ctx->infd);
 		switch (stream_mode)