diff --git a/gst/mpegstream/gstdvddemux.c b/gst/mpegstream/gstdvddemux.c
index c6e915d95a..8faadea4cb 100644
--- a/gst/mpegstream/gstdvddemux.c
+++ b/gst/mpegstream/gstdvddemux.c
@@ -963,7 +963,7 @@ gst_dvd_demux_combine_flows (GstMPEGDemux * mpegdemux, GstMPEGStream * stream,
   stream->last_flow = flow;
 
   /* if it's success we can return the value right away */
-  if (GST_FLOW_IS_SUCCESS (flow))
+  if (flow == GST_FLOW_OK)
     goto done;
 
   /* any other error that is not-linked can be returned right
diff --git a/gst/mpegstream/gstmpegdemux.c b/gst/mpegstream/gstmpegdemux.c
index ae05efc031..142a038fdb 100644
--- a/gst/mpegstream/gstmpegdemux.c
+++ b/gst/mpegstream/gstmpegdemux.c
@@ -954,7 +954,7 @@ gst_mpeg_demux_combine_flows (GstMPEGDemux * demux, GstMPEGStream * stream,
   stream->last_flow = flow;
 
   /* if it's success we can return the value right away */
-  if (GST_FLOW_IS_SUCCESS (flow))
+  if (flow == GST_FLOW_OK)
     goto done;
 
   /* any other error that is not-linked can be returned right
diff --git a/gst/mpegstream/gstmpegparse.c b/gst/mpegstream/gstmpegparse.c
index 2a9d13ccbf..f80b2bf93e 100644
--- a/gst/mpegstream/gstmpegparse.c
+++ b/gst/mpegstream/gstmpegparse.c
@@ -837,7 +837,7 @@ gst_mpeg_parse_chain (GstPad * pad, GstBuffer * buffer)
           ", total since SCR: %" G_GINT64_FORMAT ", br: %" G_GINT64_FORMAT
           ", next SCR: %" G_GINT64_FORMAT, size, bss, br, mpeg_parse->next_scr);
     }
-  } while (GST_FLOW_IS_SUCCESS (result));
+  } while (result != GST_FLOW_OK);
 
   if (result != GST_FLOW_OK) {
     GST_DEBUG_OBJECT (mpeg_parse, "flow: %s", gst_flow_get_name (result));