-> Result<(), CSE>
where R: Read, W: Write
{
- let /*mut*/ bulk_download:
- &mut dyn FnMut(&mut dyn Write) -> Result<(),MgmtChannelWriteError>
- = &mut |_| Ok(());
+ let /*mut*/ bulk_download: Option<Box<dyn Read>> = None;
let mut cmd_s = log_enabled!(log::Level::Info)
.as_some_from(|| format!("{:?}", &cmd))
};
let mut wf = for_response.write_withbulk(&resp).context("respond")?;
- bulk_download(&mut wf).context("download")?;
+ if let Some(mut bulk_download) = bulk_download {
+ io::copy(&mut bulk_download, &mut wf).context("download")?;
+ }
wf.finish().context("flush")?;
Ok(())
}