Skip to content

Commit 71e1ce8

Browse files
committed
Update RPCBlockTrackingSubscriber to use the new API for NotifyBlock
1 parent d36af20 commit 71e1ce8

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

services/ingestion/block_tracking_subscriber.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,12 @@ func (r *RPCBlockTrackingSubscriber) subscribe(ctx context.Context, height uint6
219219
for _, evt := range blockEvents.Events {
220220
r.keyLock.NotifyTransaction(evt.TransactionID)
221221
}
222-
r.keyLock.NotifyBlock(blockHeader.Height)
222+
r.keyLock.NotifyBlock(
223+
flow.BlockHeader{
224+
ID: blockEvents.BlockID,
225+
Height: blockEvents.Height,
226+
},
227+
)
223228
lastReceivedHeight = blockHeader.Height
224229

225230
eventsChan <- evmEvents

0 commit comments

Comments
 (0)