feat(requestmanager): correct for notification refactor

Resolve discripencies with new and old notification interfaces
ipfs · Dec 10, 2020 · d063643 · d063643
1 parent 4ac76cf
commit d063643
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/requestmanager/requestmanager.go b/requestmanager/requestmanager.go
@@ -562,9 +562,11 @@ func (r *reqSubscriber) OnNext(topic notifications.Topic, event notifications.Ev
 func (r reqSubscriber) OnClose(topic notifications.Topic) {
 }
 
+const requestNetworkError = "request_network_error"
+
 func (rm *RequestManager) sendRequest(p peer.ID, request gsmsg.GraphSyncRequest) {
-	sub := notifications.NewMappableSubscriber(&reqSubscriber{p, request, rm.networkErrorListeners}, notifications.IdentityTransform)
-	failNotifee := notifications.Notifee{Topic: messagequeue.Error, Subscriber: sub}
+	sub := notifications.NewTopicDataSubscriber(&reqSubscriber{p, request, rm.networkErrorListeners})
+	failNotifee := notifications.Notifee{Data: requestNetworkError, Subscriber: sub}
 	rm.peerHandler.SendRequest(p, request, failNotifee)
 }