优化代码

This commit is contained in:
GoEdgeLab
2021-12-17 11:54:06 +08:00
parent 83bde18e88
commit 7cd0ebcf72

View File

@@ -76,6 +76,9 @@ func (this *APIStream) loop() error {
nodeStream, err := rpcClient.NodeRPC().NodeStream(ctx)
if err != nil {
if this.isQuiting {
return nil
}
return errors.Wrap(err)
}
this.stream = nodeStream