diff --git a/gio/gdbusprivate.c b/gio/gdbusprivate.c
index 7f0d6f8d8..d77ab83d6 100644
--- a/gio/gdbusprivate.c
+++ b/gio/gdbusprivate.c
@@ -1444,6 +1444,9 @@ continue_writing (GDBusWorker *worker)
 
   g_mutex_lock (worker->write_lock);
 
+  data = NULL;
+  flush_async_data = NULL;
+
   /* if we want to close the connection, that takes precedence */
   if (worker->pending_close_attempts != NULL)
     {
@@ -1453,7 +1456,6 @@ continue_writing (GDBusWorker *worker)
       g_io_stream_close_async (worker->stream, G_PRIORITY_DEFAULT,
                                NULL, iostream_close_cb,
                                _g_dbus_worker_ref (worker));
-      data = NULL;
     }
   else
     {
@@ -1466,10 +1468,6 @@ continue_writing (GDBusWorker *worker)
           if (data != NULL)
             worker->output_pending = PENDING_WRITE;
         }
-      else
-        {
-          data = NULL;
-        }
     }
 
   g_mutex_unlock (worker->write_lock);