diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-07-22 10:55:37 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-07-22 10:55:37 +0200 |
| commit | c358fe3c92da8a8454e461484737efe2a14dfd73 (patch) | |
| tree | db540e2e25a96585686826ef66f3552decee96df /src/message.rs | |
| parent | 4934ed726d51913afd97ca937d0ece39ef8b7371 (diff) | |
| download | netapp-c358fe3c92da8a8454e461484737efe2a14dfd73.tar.gz netapp-c358fe3c92da8a8454e461484737efe2a14dfd73.zip | |
Hide streaming versions as much as possible
Diffstat (limited to 'src/message.rs')
| -rw-r--r-- | src/message.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/message.rs b/src/message.rs index d918c29..5721318 100644 --- a/src/message.rs +++ b/src/message.rs @@ -311,7 +311,7 @@ impl Framing { } } - pub async fn from_stream<S: Stream<Item = Packet> + Unpin + Send + 'static>( + pub async fn from_stream<S: Stream<Item = Packet> + Unpin + Send + Sync + 'static>( mut stream: S, ) -> Result<Self, Error> { let mut packet = stream |