use core::fmt::{Arguments, Debug};
use crate::{IntoWriteFn, NeverError, WriteBytes, WriteStr};
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct ConcatWriter<F1>(F1);
pub trait ExpectConcatWriteResult {
type Output;
fn expect_concat_write_result(self) -> Self::Output;
}
impl<F1> ConcatWriter<F1>
where
F1: WriteStr,
{
pub fn new(write: F1) -> Self {
Self(write)
}
pub fn from_closure<F, Ts>(closure: F) -> Self
where
F: IntoWriteFn<Ts, WriteFn = F1>,
{
Self(closure.into_write_fn())
}
}
impl<F1> ConcatWriter<F1>
where
Self: WriteStr,
{
pub fn write_fmt(&mut self, args: Arguments<'_>) -> <Self as WriteStr>::Output {
if let Some(buf) = args.as_str() {
self.write_str(buf)
} else {
let buf = alloc::fmt::format(args);
self.write_str(&buf)
}
}
}
impl<F1, Output> WriteStr for ConcatWriter<F1>
where
F1: WriteStr,
F1::Output: ExpectConcatWriteResult<Output = Output>,
{
type Output = Output;
fn write_str(&mut self, buf: &str) -> Output {
self.0.write_str(buf).expect_concat_write_result()
}
}
impl<F1, Output> WriteBytes for ConcatWriter<F1>
where
F1: WriteBytes,
F1::Output: ExpectConcatWriteResult<Output = Output>,
{
type Output = Output;
fn write_bytes(&mut self, buf: &[u8]) -> Output {
self.0.write_bytes(buf).expect_concat_write_result()
}
}
impl ExpectConcatWriteResult for () {
type Output = Result<(), NeverError>;
fn expect_concat_write_result(self) -> Self::Output {
Ok(())
}
}
impl<T, E: Debug> ExpectConcatWriteResult for Result<T, E> {
type Output = Result<T, NeverError>;
fn expect_concat_write_result(self) -> Self::Output {
Ok(self.expect("failed writing"))
}
}