reverse

Author: gunli

pulsar/consumer_multitopic_test.go

@@ -369,10 +369,6 @@ func (dummyConnection) IsProxied() bool {
 	return false
 }
 
-func (dummyConnection) closed() bool {
-	return false
-}
-
 func TestMultiTopicAckIDListTimeout(t *testing.T) {
 	topic := fmt.Sprintf("multiTopicAckIDListTimeout%v", time.Now().UnixNano())
 	assert.NoError(t, createPartitionedTopic(topic, 5))