diff --git a/src/gst/gstpipewiresink.c b/src/gst/gstpipewiresink.c
index 654c5e555..a48786b8a 100644
--- a/src/gst/gstpipewiresink.c
+++ b/src/gst/gstpipewiresink.c
@@ -576,9 +576,10 @@ gst_pipewire_sink_setcaps (GstBaseSink * bsink, GstCaps * caps)
     goto start_error;
 
   if (state == PW_STREAM_STATE_UNCONNECTED) {
-    enum pw_stream_flags flags = 0;
+    enum pw_stream_flags flags;
     uint32_t target_id;
 
+    flags = PW_STREAM_FLAG_ASYNC;
     if (pwsink->mode != GST_PIPEWIRE_SINK_MODE_PROVIDE)
       flags |= PW_STREAM_FLAG_AUTOCONNECT;
     else
diff --git a/src/gst/gstpipewiresrc.c b/src/gst/gstpipewiresrc.c
index cee2f46af..95854259b 100644
--- a/src/gst/gstpipewiresrc.c
+++ b/src/gst/gstpipewiresrc.c
@@ -892,7 +892,9 @@ gst_pipewire_src_negotiate (GstBaseSrc * basesrc)
   GST_DEBUG_OBJECT (basesrc, "connect capture with path %s, target-object %s",
                     pwsrc->path, pwsrc->target_object);
   pwsrc->negotiated = FALSE;
-  enum pw_stream_flags flags = PW_STREAM_FLAG_DONT_RECONNECT;
+  enum pw_stream_flags flags;
+  flags = PW_STREAM_FLAG_DONT_RECONNECT |
+	  PW_STREAM_FLAG_ASYNC;
   if (pwsrc->autoconnect)
     flags |= PW_STREAM_FLAG_AUTOCONNECT;
   pw_stream_connect (pwsrc->stream,