actix/actix-net
1
0
Fork 0
mirror of https://github.com/fafhrd91/actix-net synced 2025-03-29 07:15:42 +01:00
Code Issues Releases Wiki Activity

impl Clone for TakeItem and TakeItemService

Browse Source
This commit is contained in:
Nikolay Kim 2018-11-01 11:03:03 -07:00
parent dc19a9f862
commit 6c25becd3f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/stream.rs
View File

@ -103,6 +103,12 @@ impl<T> TakeItem<T> {
} }
} }
impl<T> Clone for TakeItem<T> {
fn clone(&self) -> TakeItem<T> {
TakeItem { _t: PhantomData }
}
}
impl<T: Stream> NewService for TakeItem<T> { impl<T: Stream> NewService for TakeItem<T> {
type Request = T; type Request = T;
type Response = (Option<T::Item>, T); type Response = (Option<T::Item>, T);
@ -121,6 +127,12 @@ pub struct TakeItemService<T> {
_t: PhantomData<T>, _t: PhantomData<T>,
} }
impl<T> Clone for TakeItemService<T> {
fn clone(&self) -> TakeItemService<T> {
TakeItemService { _t: PhantomData }
}
}
impl<T: Stream> Service for TakeItemService<T> { impl<T: Stream> Service for TakeItemService<T> {
type Request = T; type Request = T;
type Response = (Option<T::Item>, T); type Response = (Option<T::Item>, T);