todo clean up
This commit is contained in:
@@ -214,7 +214,6 @@ fn generate_unary(
|
|||||||
Ok(res)
|
Ok(res)
|
||||||
};
|
};
|
||||||
|
|
||||||
// TODO: implement this future manually
|
|
||||||
Box::pin(fut)
|
Box::pin(fut)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -38,6 +38,7 @@ impl Server {
|
|||||||
pub struct Builder {
|
pub struct Builder {
|
||||||
tls: Option<(Vec<u8>, Vec<u8>)>,
|
tls: Option<(Vec<u8>, Vec<u8>)>,
|
||||||
interceptor: Option<Interceptor>,
|
interceptor: Option<Interceptor>,
|
||||||
|
// concurrency_limit: Option<usize>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl Builder {
|
impl Builder {
|
||||||
@@ -50,7 +51,10 @@ impl Builder {
|
|||||||
self
|
self
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// FIXME: add server side layering ability
|
||||||
// pub fn concurrency_limit(&mut self, limit: usize) -> &mut Self {
|
// pub fn concurrency_limit(&mut self, limit: usize) -> &mut Self {
|
||||||
|
// self.concurrency_limit = Some(limit);
|
||||||
|
// self
|
||||||
// }
|
// }
|
||||||
|
|
||||||
pub fn interceptor_fn<F, Out>(&mut self, f: F) -> &mut Self
|
pub fn interceptor_fn<F, Out>(&mut self, f: F) -> &mut Self
|
||||||
|
|||||||
Reference in New Issue
Block a user