Unverified Commit 8d8858c0 authored by Alexandru Vasile's avatar Alexandru Vasile
Browse files

server: Make `pipe` methods of `SubscriptionSink` private


Signed-off-by: default avatarAlexandru Vasile <alexandru.vasile@parity.io>
parent f95403ee
...@@ -1050,7 +1050,7 @@ impl SubscriptionSink { ...@@ -1050,7 +1050,7 @@ impl SubscriptionSink {
/// Ok(()) /// Ok(())
/// }); /// });
/// ``` /// ```
pub async fn pipe_from_try_stream<S, T, E>(&mut self, mut stream: S) -> SubscriptionClosed async fn pipe_from_try_stream<S, T, E>(&mut self, mut stream: S) -> SubscriptionClosed
where where
S: TryStream<Ok = T, Error = E> + Unpin, S: TryStream<Ok = T, Error = E> + Unpin,
T: Serialize, T: Serialize,
...@@ -1123,7 +1123,7 @@ impl SubscriptionSink { ...@@ -1123,7 +1123,7 @@ impl SubscriptionSink {
/// Ok(()) /// Ok(())
/// }); /// });
/// ``` /// ```
pub async fn pipe_from_stream<S, T>(&mut self, stream: S) -> SubscriptionClosed async fn pipe_from_stream<S, T>(&mut self, stream: S) -> SubscriptionClosed
where where
S: Stream<Item = T> + Unpin, S: Stream<Item = T> + Unpin,
T: Serialize, T: Serialize,
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment