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)
 	}