renamed StreamDisconnect to OnDisconnect

libp2p · May 12, 2021 · c22b4bf · c22b4bf
1 parent 1b0922d
commit c22b4bf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/internal/net/message_manager.go b/internal/net/message_manager.go
@@ -49,7 +49,7 @@ func NewMessageSenderImpl(h host.Host, protos []protocol.ID) pb.MessageSender {
 	}
 }
 
-func (m *messageSenderImpl) StreamDisconnect(ctx context.Context, p peer.ID) {
+func (m *messageSenderImpl) OnDisconnect(ctx context.Context, p peer.ID) {
 	m.smlk.Lock()
 	defer m.smlk.Unlock()
 	ms, ok := m.strmap[p]

diff --git a/subscriber_notifee.go b/subscriber_notifee.go
@@ -156,7 +156,7 @@ func (dht *IpfsDHT) validRTPeer(p peer.ID) (bool, error) {
 }
 
 type disconnector interface {
-	StreamDisconnect(ctx context.Context, p peer.ID)
+	OnDisconnect(ctx context.Context, p peer.ID)
 }
 
 func (nn *subscriberNotifee) Disconnected(n network.Network, v network.Conn) {
@@ -179,7 +179,7 @@ func (nn *subscriberNotifee) Disconnected(n network.Network, v network.Conn) {
 	}
 
 	if ms, ok := dht.msgSender.(disconnector); ok {
-		ms.StreamDisconnect(dht.Context(), p)
+		ms.OnDisconnect(dht.Context(), p)
 	}
 }