use std::{fmt, marker::PhantomData, time::Duration};
use tower::{layer::Layer, Service};
use super::{service::Batch, BatchControl};
pub struct BatchLayer<Request> {
size: usize,
time: Duration,
_p: PhantomData<fn(Request)>,
}
impl<Request> BatchLayer<Request> {
pub fn new(size: usize, time: Duration) -> Self {
Self {
size,
time,
_p: PhantomData,
}
}
}
impl<S, Request> Layer<S> for BatchLayer<Request>
where
S: Service<BatchControl<Request>> + Send + 'static,
S::Future: Send,
S::Error: Into<crate::BoxError> + Send + Sync,
Request: Send + 'static,
{
type Service = Batch<S, Request>;
fn layer(&self, service: S) -> Self::Service {
Batch::new(service, self.size, self.time)
}
}
impl<Request> fmt::Debug for BatchLayer<Request> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.debug_struct("BufferLayer")
.field("size", &self.size)
.field("time", &self.time)
.finish()
}
}