Signed-off-by: Ian Jackson <ijackson@chiark.greenend.org.uk>
reply_to, warnings,
} = req.ok_or_else(|| anyhow!("webservers all shut down!"))?;
reply_to, warnings,
} = req.ok_or_else(|| anyhow!("webservers all shut down!"))?;
+ match async {
+ let whole_request =
+ StreamExt::chain(
+ stream::once(Ok(
+ &initial[initial_remaining..]
+ )),
+ body.map_ok(
+ |by| &*by
+ ),
+ )
+ .try_collect().await.context("read request body")?;
+/*
+
+ multipart::ComponentIterator::resume_mid_component(
+ &initial[initial_remaining..],
+ */
+
Ok(()) => outstanding.push_back(Outstanding {
reply_to: reply_to,
max_requests_outstanding: 42, // xxx
Ok(()) => outstanding.push_back(Outstanding {
reply_to: reply_to,
max_requests_outstanding: 42, // xxx