@@ -39,6 +39,7 @@ import (
3939 "github.com/onflow/flow/protobuf/go/flow/entities"
4040 "github.com/onflow/flow/protobuf/go/flow/executiondata"
4141
42+ base "github.com/onflow/flow-go-sdk/access"
4243 "github.com/onflow/flow-go-sdk/access/grpc/convert"
4344 "github.com/onflow/flow-go-sdk/access/grpc/mocks"
4445
@@ -1987,7 +1988,7 @@ func TestClient_SubscribeEvents(t *testing.T) {
19871988 Return (stream , nil ).
19881989 Run (assertSubscribeEventsArgs (t , & req ))
19891990
1990- eventCh , errCh , err := c .SubscribeEventsByBlockHeight (ctx , startHeight , filter , WithHeartbeatInterval (req .HeartbeatInterval ))
1991+ eventCh , errCh , err := c .SubscribeEventsByBlockHeight (ctx , startHeight , filter , base . WithHeartbeatInterval (req .HeartbeatInterval ))
19911992 require .NoError (t , err )
19921993
19931994 wg := sync.WaitGroup {}
@@ -2040,7 +2041,7 @@ func TestClient_SubscribeEvents(t *testing.T) {
20402041 Return (stream , nil ).
20412042 Run (assertSubscribeEventsArgs (t , & req ))
20422043
2043- eventCh , errCh , err := c .SubscribeEventsByBlockID (ctx , startBlockID , filter , WithHeartbeatInterval (req .HeartbeatInterval ))
2044+ eventCh , errCh , err := c .SubscribeEventsByBlockID (ctx , startBlockID , filter , base . WithHeartbeatInterval (req .HeartbeatInterval ))
20442045 require .NoError (t , err )
20452046
20462047 wg := sync.WaitGroup {}
@@ -2131,7 +2132,7 @@ func TestClient_SubscribeEvents(t *testing.T) {
21312132 Return (stream , nil ).
21322133 Run (assertSubscribeEventsArgs (t , & req ))
21332134
2134- eventCh , errCh , err := c .SubscribeEventsByBlockHeight (ctx , startHeight , filter , WithHeartbeatInterval (req .HeartbeatInterval ))
2135+ eventCh , errCh , err := c .SubscribeEventsByBlockHeight (ctx , startHeight , filter , base . WithHeartbeatInterval (req .HeartbeatInterval ))
21352136 require .NoError (t , err )
21362137
21372138 wg := sync.WaitGroup {}
0 commit comments