diff --git a/src/stream.rs b/src/stream.rs index bee5ec64..5b08f441 100644 --- a/src/stream.rs +++ b/src/stream.rs @@ -103,6 +103,12 @@ impl TakeItem { } } +impl Clone for TakeItem { + fn clone(&self) -> TakeItem { + TakeItem { _t: PhantomData } + } +} + impl NewService for TakeItem { type Request = T; type Response = (Option, T); @@ -121,6 +127,12 @@ pub struct TakeItemService { _t: PhantomData, } +impl Clone for TakeItemService { + fn clone(&self) -> TakeItemService { + TakeItemService { _t: PhantomData } + } +} + impl Service for TakeItemService { type Request = T; type Response = (Option, T);