diff --git a/ext/gme/gstgme.c b/ext/gme/gstgme.c
index eda7e3f27a..7a70c7a3c6 100644
--- a/ext/gme/gstgme.c
+++ b/ext/gme/gstgme.c
@@ -380,10 +380,9 @@ gst_gme_play (GstPad * pad)
 
     gst_pad_pause_task (pad);
 
-    if (flow_return == GST_FLOW_UNEXPECTED) {
+    if (flow_return == GST_FLOW_EOS) {
       gst_pad_push_event (pad, gst_event_new_eos ());
-    } else if (flow_return < GST_FLOW_UNEXPECTED
-        || flow_return == GST_FLOW_NOT_LINKED) {
+    } else if (flow_return < GST_FLOW_EOS || flow_return == GST_FLOW_NOT_LINKED) {
       GST_ELEMENT_ERROR (gme, STREAM, FAILED, ("Internal data stream error."),
           ("stream stopped, reason %s", gst_flow_get_name (flow_return)));
 
diff --git a/ext/rtmp/gstrtmpsrc.c b/ext/rtmp/gstrtmpsrc.c
index 28f5ea5689..1f0ba85196 100644
--- a/ext/rtmp/gstrtmpsrc.c
+++ b/ext/rtmp/gstrtmpsrc.c
@@ -379,7 +379,7 @@ eos:
   {
     gst_buffer_unref (buf);
     GST_DEBUG_OBJECT (src, "Reading data gave EOS");
-    return GST_FLOW_UNEXPECTED;
+    return GST_FLOW_EOS;
   }
 }