as_ref,
).map(|b| b.len()).sum();
- trace!("{} #{}: frames={} bytes={}",
- &c.ic, req_num, upbound.len(), body_len);
+ trace!("{} #{}: req; tx bytes={} frames={}",
+ &c.ic, req_num, body_len, upbound.len());
let body = hyper::body::Body::wrap_stream(
futures::stream::iter(
let r = c.reporter.lock().filter(Some(req_num), r);
- if r.is_none() {
+ if let Some(r) = &r {
+ trace!("{} #{}: rok; rx bytes={}", &c.ic, req_num, r.len());
+ } else {
tokio::time::sleep(c.ic.http_retry).await;
}
r