diff --git a/pkg/twap/v2/bbomonitor.go b/pkg/twap/v2/bbomonitor.go index 5081fc9bb..b76a6bdce 100644 --- a/pkg/twap/v2/bbomonitor.go +++ b/pkg/twap/v2/bbomonitor.go @@ -21,7 +21,7 @@ func NewBboMonitor() *BboMonitor { return &BboMonitor{} } -func (m *BboMonitor) OnUpdateFromBook(book *types.StreamOrderBook) bool { +func (m *BboMonitor) UpdateFromBook(book *types.StreamOrderBook) bool { bestBid, ok1 := book.BestBid() bestAsk, ok2 := book.BestAsk() if !ok1 || !ok2 { diff --git a/pkg/twap/v2/stream_executor.go b/pkg/twap/v2/stream_executor.go index 4cd21a921..51e56b8d6 100644 --- a/pkg/twap/v2/stream_executor.go +++ b/pkg/twap/v2/stream_executor.go @@ -276,7 +276,7 @@ func (e *FixedQuantityExecutor) orderUpdater(ctx context.Context) { return case <-e.orderBook.C: - changed := monitor.OnUpdateFromBook(e.orderBook) + changed := monitor.UpdateFromBook(e.orderBook) if !changed { continue } @@ -293,7 +293,7 @@ func (e *FixedQuantityExecutor) orderUpdater(ctx context.Context) { } case <-ticker.C: - changed := monitor.OnUpdateFromBook(e.orderBook) + changed := monitor.UpdateFromBook(e.orderBook) if !changed { continue }