aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-09-13 11:52:35 +0200
committerAlex Auvolat <alex@adnab.me>2022-09-13 11:52:35 +0200
commitadd2b54743a76bf805b0dc5ab7a1d8d326445314 (patch)
tree0e4fe047a3c51312ecc29a465fd9a0d1843caca5
parentbf0e82047f0a54d71ce048ed8f5e1584485b542c (diff)
downloadnetapp-add2b54743a76bf805b0dc5ab7a1d8d326445314.tar.gz
netapp-add2b54743a76bf805b0dc5ab7a1d8d326445314.zip
fix comment
-rw-r--r--src/endpoint.rs4
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)
}