Skip to content

Commit 02b2ac7

Browse files
committed
Export CancelInfLightRequests
1 parent 959b04c commit 02b2ac7

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

multinode/adaptor.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -269,16 +269,16 @@ func (m *MultiNodeAdapter[RPC, HEAD]) UnsubscribeAllExcept(subs ...Subscription)
269269
}
270270
}
271271

272-
// cancelInflightRequests closes and replaces the chStopInFlight
273-
func (m *MultiNodeAdapter[RPC, HEAD]) cancelInflightRequests() {
272+
// CancelInflightRequests closes and replaces the chStopInFlight
273+
func (m *MultiNodeAdapter[RPC, HEAD]) CancelInflightRequests() {
274274
m.stateMu.Lock()
275275
defer m.stateMu.Unlock()
276276
close(m.chStopInFlight)
277277
m.chStopInFlight = make(chan struct{})
278278
}
279279

280280
func (m *MultiNodeAdapter[RPC, HEAD]) Close() {
281-
m.cancelInflightRequests()
281+
m.CancelInflightRequests()
282282
m.UnsubscribeAllExcept()
283283
m.chainInfoLock.Lock()
284284
m.latestChainInfo = ChainInfo{}

0 commit comments

Comments
 (0)