diff options
| author | Alex Auvolat <alex@adnab.me> | 2022-09-13 11:52:35 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2022-09-13 11:52:35 +0200 |
| commit | add2b54743a76bf805b0dc5ab7a1d8d326445314 (patch) | |
| tree | 0e4fe047a3c51312ecc29a465fd9a0d1843caca5 /src/endpoint.rs | |
| parent | bf0e82047f0a54d71ce048ed8f5e1584485b542c (diff) | |
| download | netapp-add2b54743a76bf805b0dc5ab7a1d8d326445314.tar.gz netapp-add2b54743a76bf805b0dc5ab7a1d8d326445314.zip | |
fix comment
Diffstat (limited to 'src/endpoint.rs')
| -rw-r--r-- | src/endpoint.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/endpoint.rs b/src/endpoint.rs index 015000b..3cafafe 100644 --- a/src/endpoint.rs +++ b/src/endpoint.rs @@ -53,8 +53,8 @@ where M: Message, { async fn handle(self: &Arc<Self>, mut m: Req<M>, from: NodeID) -> Resp<M> { - // Immediately drop stream to avoid backpressure if a stream was sent - // (this will make all data sent to the stream be ignored immediately) + // Immediately drop stream to ignore all data that comes in, + // instead of buffering it indefinitely drop(m.take_stream()); Resp::new(EndpointHandler::handle(self, m.msg(), from).await) } |