Progress towards workqueue transition

1 files changed, 2 insertions, 1 deletions

diff --git a/src/core/client_config/subchannel.c b/src/core/client_config/subchannel.c
index ca52c75beb..0718ffbb8c 100644
--- a/src/core/client_config/subchannel.c
+++ b/src/core/client_config/subchannel.c
@@ -76,6 +76,7 @@ typedef struct waiting_for_connect {
 
 struct grpc_subchannel {
   grpc_connector *connector;
+  grpc_workqueue *workqueue;
 
   /** non-transport related channel filters */
   const grpc_channel_filter **filters;
@@ -575,7 +576,7 @@ static void publish_transport(grpc_subchannel *c) {
   connectivity_state_changed_locked(c, "connected");
   while ((w4c = c->waiting)) {
     c->waiting = w4c->next;
-    grpc_iomgr_add_callback(&w4c->continuation);
+    grpc_workqueue_push(c->workqueue, &w4c->continuation, 1);
   }
 
   gpr_mu_unlock(&c->mu);