From 8a9aac7d7248917cfef8db1121ad2b7ad52b6050 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Mon, 11 Dec 2023 20:35:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/nodes/api_stream.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/nodes/api_stream.go b/internal/nodes/api_stream.go index 9b4c4cb..8a58a2f 100644 --- a/internal/nodes/api_stream.go +++ b/internal/nodes/api_stream.go @@ -90,13 +90,13 @@ func (this *APIStream) loop() error { break } - message, err := nodeStream.Recv() - if err != nil { + message, streamErr := nodeStream.Recv() + if streamErr != nil { if this.isQuiting { remotelogs.Println("API_STREAM", "quit") return nil } - return err + return streamErr } // 处理消息