From: Ian Jackson <ijackson@chiark.greenend.org.uk>
Date: Mon, 2 Aug 2021 01:02:05 +0000 (+0100)
Subject: wip rx
X-Git-Tag: hippotat/1.0.0~382
X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ian/git?a=commitdiff_plain;h=505ad41f85b44550416e8c3e9084047e9eb93723;p=hippotat.git

wip rx

Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>
---

diff --git a/src/bin/client.rs b/src/bin/client.rs
index 080ced9..b43fc59 100644
--- a/src/bin/client.rs
+++ b/src/bin/client.rs
@@ -140,6 +140,7 @@ fn submit_request<'r, 'c:'r, C:HCC>(
 }
 
 #[allow(unused_variables)] // xxx
+#[allow(unused_mut)] // xxx
 async fn run_client<C:HCC>(
   ic: InstanceConfig,
   hclient: Arc<hyper::Client<C>>
@@ -174,15 +175,17 @@ async fn run_client<C:HCC>(
   });
 
   let tx_stream = ipif.stdout.take().unwrap();
+  let rx_stream = ipif.stdin .take().unwrap();
+
   let mut tx_stream = tokio::io::BufReader::new(tx_stream).split(SLIP_END);
   let mut packets: VecDeque<Box<[u8]>> = default();
   let mut upbound = Frames::default();
 
-  let stream_for_rx = ipif.stdin .take().unwrap();
-
   let mut reqs: Vec<OutstandingRequest>
     = Vec::with_capacity(ic.max_requests_outstanding.sat());
 
+  let mut inbound: VecDeque<Box<[u8]>> = default();
+
   // xxx check that ic settings are all honoured
 
   async {