Preserve runtime output stream order

exe-unit/runtime-api/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ya-runtime-api"
-version = "0.1.1"
+version = "0.1.2"
 authors = ["Golem Factory <contact@golem.network>"]
 edition = "2018"
 

exe-unit/runtime-api/src/server/service.rs

@@ -85,14 +85,9 @@ where
         async move {
             while let Some(event) = rx.next().await {
                 log::debug!("event: {:?}", event);
-                tokio::task::spawn_local({
-                    let output = output.clone();
-                    async move {
-                        let mut output = output.lock().await;
-                        let r = SinkExt::send(&mut *output, event).await;
-                        log::debug!("sending event done: {:?}", r);
-                    }
-                });
+                let mut output = output.lock().await;
+                let r = SinkExt::send(&mut *output, event).await;
+                log::debug!("sending event done: {:?}", r);
             }
         }
     });

service-bus/bus/src/connection.rs

@@ -373,7 +373,7 @@ where
                     Err(Error::GsbFailure(String::from_utf8(chunk.into_bytes())?))
                 }
             };
-            let _ = ctx.spawn(
+            let _ = ctx.wait(
                 async move {
                     let s = r.send(item);
                     s.await
@@ -401,7 +401,8 @@ where
 {
     type Context = Context<Self>;
 
-    fn started(&mut self, _ctx: &mut Self::Context) {
+    fn started(&mut self, ctx: &mut Self::Context) {
+        ctx.set_mailbox_capacity(256);
         log::info!("started connection to gsb");
     }