@@ -70,7 +70,7 @@ impl Client {
70 process: Option<Child>,
70 process: Option<Child>,
71 ) -> Result<(Self, UnboundedReceiver<Payload>)> {
71 ) -> Result<(Self, UnboundedReceiver<Payload>)> {
72 let (server_rx, server_tx) = Transport::start(rx, tx, err, id);
72 let (server_rx, server_tx) = Transport::start(rx, tx, err, id);
73− let (client_rx, client_tx) = unbounded_channel();
73+ let (client_tx, client_rx) = unbounded_channel();
75 let client = Self {
75 let client = Self {
@@ -86,9 +86,9 @@ impl Client {
86 quirks: DebuggerQuirks::default(),
86 quirks: DebuggerQuirks::default(),
89− tokio::spawn(Self::recv(server_rx, client_rx));
89+ tokio::spawn(Self::recv(server_rx, client_tx));
91− Ok((client, client_tx))
91+ Ok((client, client_rx))
94 pub async fn tcp(
94 pub async fn tcp(