From add2b54743a76bf805b0dc5ab7a1d8d326445314 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Tue, 13 Sep 2022 11:52:35 +0200 Subject: [PATCH] fix comment --- src/endpoint.rs | 4 ++-- 1 file 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, mut m: Req, from: NodeID) -> Resp { - // 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) }