diff options
author | Alice Ryhl <alice@ryhl.io> | 2020-10-05 19:33:15 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-10-05 10:33:15 -0700 |
commit | aa171f2aa9593f64e78bde2c679a4c9bd9d9d163 (patch) | |
tree | 09998d736e1d352a65bf94012e6c93c7be481226 /tokio/src | |
parent | c23c1ecbcbd7ff8e1ee137f691eddad31aa39331 (diff) |
stream: remove bytes from public API (#2908)
Diffstat (limited to 'tokio/src')
-rw-r--r-- | tokio/src/stream/collect.rs | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/tokio/src/stream/collect.rs b/tokio/src/stream/collect.rs index 3f91a6f2..1aafc303 100644 --- a/tokio/src/stream/collect.rs +++ b/tokio/src/stream/collect.rs @@ -1,6 +1,5 @@ use crate::stream::Stream; -use bytes::{Buf, BufMut, Bytes, BytesMut}; use core::future::Future; use core::marker::PhantomPinned; use core::mem; @@ -205,44 +204,6 @@ where } } -impl<T: Buf> FromStream<T> for Bytes {} - -impl<T: Buf> sealed::FromStreamPriv<T> for Bytes { - type InternalCollection = BytesMut; - - fn initialize(_: sealed::Internal, _lower: usize, _upper: Option<usize>) -> BytesMut { - BytesMut::new() - } - - fn extend(_: sealed::Internal, collection: &mut BytesMut, item: T) -> bool { - collection.put(item); - true - } - - fn finalize(_: sealed::Internal, collection: &mut BytesMut) -> Bytes { - mem::replace(collection, BytesMut::new()).freeze() - } -} - -impl<T: Buf> FromStream<T> for BytesMut {} - -impl<T: Buf> sealed::FromStreamPriv<T> for BytesMut { - type InternalCollection = BytesMut; - - fn initialize(_: sealed::Internal, _lower: usize, _upper: Option<usize>) -> BytesMut { - BytesMut::new() - } - - fn extend(_: sealed::Internal, collection: &mut BytesMut, item: T) -> bool { - collection.put(item); - true - } - - fn finalize(_: sealed::Internal, collection: &mut BytesMut) -> BytesMut { - mem::replace(collection, BytesMut::new()) - } -} - pub(crate) mod sealed { #[doc(hidden)] pub trait FromStreamPriv<T> { |