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 080ced93700972dd9dcf09c309732f5b48cc14e2..b43fc594f1ba7ef652eb14bbca263ebd2b8d7e41 100644 (file)
--- 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 {