Skip to content

Commit 269a4ea

Browse files
committed
reverse
1 parent d965634 commit 269a4ea

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

pulsar/consumer_multitopic_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -369,7 +369,7 @@ func (dummyConnection) IsProxied() bool {
369369
return false
370370
}
371371

372-
func (dummyConnection) Closed() bool {
372+
func (dummyConnection) closed() bool {
373373
return false
374374
}
375375

pulsar/internal/connection_reader.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,8 @@ import (
2121
"fmt"
2222
"io"
2323

24-
"google.golang.org/protobuf/proto"
25-
2624
pb "github.com/apache/pulsar-client-go/pulsar/internal/pulsar_proto"
25+
"google.golang.org/protobuf/proto"
2726
)
2827

2928
type connectionReader struct {

0 commit comments

Comments
 (0)