Archived
优化代码
This commit is contained in:
@@ -90,13 +90,13 @@ func (this *APIStream) loop() error {
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
message, err := nodeStream.Recv()
|
message, streamErr := nodeStream.Recv()
|
||||||
if err != nil {
|
if streamErr != nil {
|
||||||
if this.isQuiting {
|
if this.isQuiting {
|
||||||
remotelogs.Println("API_STREAM", "quit")
|
remotelogs.Println("API_STREAM", "quit")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
return err
|
return streamErr
|
||||||
}
|
}
|
||||||
|
|
||||||
// 处理消息
|
// 处理消息
|
||||||
|
|||||||
Reference in New Issue
Block a user