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 3cc9fe8 commit 74b18d1Copy full SHA for 74b18d1
pulsar/consumer_multitopic_test.go
@@ -369,7 +369,7 @@ func (dummyConnection) IsProxied() bool {
369
return false
370
}
371
372
-func (dummyConnection) Closed() bool {
+func (dummyConnection) closed() bool {
373
374
375
pulsar/internal/connection_reader.go
@@ -21,9 +21,8 @@ import (
21
"fmt"
22
"io"
23
24
- "google.golang.org/protobuf/proto"
25
-
26
pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
+ "google.golang.org/protobuf/proto"
27
)
28
29
type connectionReader struct {
0 commit comments