Add msg queuing for all messages for public agents

Fixes #944

src/agent.rs

@@ -645,7 +645,9 @@ impl Discoverer for Public {
                         }),
                     };
                     let launched = RemoteAgent::new(worker, slab);
-                    entry.insert(launched).create_bridge(callback)
+                    let bridge = entry.insert(launched).create_bridge(callback);
+                    bridge.send_message(ToWorker::Connected(bridge.id));
+                    bridge
                 }
             }
         });
@@ -689,6 +691,14 @@ impl<AGN: Agent> PublicBridge<AGN> {
             }
         });
     }
+
+    fn send_message(&self, msg: ToWorker<AGN::Input>) {
+        if self.worker_is_loaded() {
+            send_to_remote::<AGN>(&self.worker, msg);
+        } else {
+            self.msg_to_queue(msg.pack());
+        }
+    }
 }
 
 fn send_to_remote<AGN: Agent>(
@@ -713,11 +723,7 @@ fn send_to_remote<AGN: Agent>(
 impl<AGN: Agent> Bridge<AGN> for PublicBridge<AGN> {
     fn send(&mut self, msg: AGN::Input) {
         let msg = ToWorker::ProcessInput(self.id, msg);
-        if self.worker_is_loaded() {
-            send_to_remote::<AGN>(&self.worker, msg);
-        } else {
-            self.msg_to_queue(msg.pack());
-        }
+        self.send_message(msg);
     }
 }