@@ -8404,16 +8404,16 @@ func (t *testSubscriptionUpdaterChan) Update(data []byte) {
84048404}
84058405
84068406// empty method to satisfy the interface, not used in this tests
8407- func (t * testSubscriptionUpdaterChan ) UpdateSubscription (id resolve.SubscriptionIdentifier , data []byte ) {
8407+ func (t * testSubscriptionUpdaterChan ) UpdateSubscription (ctx * resolve. Context , id resolve.SubscriptionIdentifier , data []byte ) {
84088408}
84098409
84108410// empty method to satisfy the interface, not used in this tests
84118411func (t * testSubscriptionUpdaterChan ) CloseSubscription (kind resolve.SubscriptionCloseKind , id resolve.SubscriptionIdentifier ) {
84128412}
84138413
84148414// empty method to satisfy the interface, not used in this tests
8415- func (t * testSubscriptionUpdaterChan ) Subscriptions () map [context .Context ]resolve.SubscriptionIdentifier {
8416- return make (map [context .Context ]resolve.SubscriptionIdentifier )
8415+ func (t * testSubscriptionUpdaterChan ) Subscriptions () map [* resolve .Context ]resolve.SubscriptionIdentifier {
8416+ return make (map [* resolve .Context ]resolve.SubscriptionIdentifier )
84178417}
84188418
84198419func (t * testSubscriptionUpdaterChan ) Complete () {
@@ -8546,12 +8546,12 @@ func (t *testSubscriptionUpdater) CloseSubscription(kind resolve.SubscriptionClo
85468546}
85478547
85488548// empty method to satisfy the interface, not used in this tests
8549- func (t * testSubscriptionUpdater ) Subscriptions () map [context .Context ]resolve.SubscriptionIdentifier {
8550- return make (map [context .Context ]resolve.SubscriptionIdentifier )
8549+ func (t * testSubscriptionUpdater ) Subscriptions () map [* resolve .Context ]resolve.SubscriptionIdentifier {
8550+ return make (map [* resolve .Context ]resolve.SubscriptionIdentifier )
85518551}
85528552
85538553// empty method to satisfy the interface, not used in this tests
8554- func (t * testSubscriptionUpdater ) UpdateSubscription (id resolve.SubscriptionIdentifier , data []byte ) {
8554+ func (t * testSubscriptionUpdater ) UpdateSubscription (ctx * resolve. Context , id resolve.SubscriptionIdentifier , data []byte ) {
85558555}
85568556
85578557func TestSubscriptionSource_Start (t * testing.T ) {
0 commit comments