wip

cli/src/msgpack_rpc.rs

@@ -34,6 +34,7 @@ pub fn new_msgpack_rpc() -> rpc::RpcBuilder<MsgPackSerializer> {
 	rpc::RpcBuilder::new(MsgPackSerializer {})
 }
 
+#[allow(clippy::read_zero_byte_vec)] // false positive
 pub async fn start_msgpack_rpc<C: Send + Sync + 'static, S>(
 	dispatcher: rpc::RpcDispatcher<MsgPackSerializer, C>,
 	read: impl AsyncRead + Unpin,
@@ -76,5 +77,7 @@ pub async fn start_msgpack_rpc<C: Send + Sync + 'static, S>(
 			},
 			r = shutdown_rx.recv() => return Ok(r),
 		}
+
+		write.flush().await?;
 	}
 }