We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 55fa64f commit d4f89dbCopy full SHA for d4f89db
1 file changed
datastore/catalog/remote/grpc.go
@@ -2,6 +2,7 @@ package remote
2
3
import (
4
"context"
5
+ "errors"
6
"fmt"
7
"sync"
8
"time"
@@ -93,12 +94,13 @@ func (c *CatalogClient) CloseStream() error {
93
94
// Close closes the underlying gRPC connection.
95
func (c *CatalogClient) Close() error {
96
if c.cachedStream != nil {
- return fmt.Errorf("stream is not closed")
97
+ return errors.New("stream is not closed")
98
}
99
100
if c.conn != nil {
101
return c.conn.Close()
102
103
+
104
return nil
105
106
0 commit comments