TP-61989 | replaced send with trySend (#10189)
This commit is contained in:
committed by
GitHub
parent
92e23acd0a
commit
b9d8c6777e
@@ -43,7 +43,7 @@ class NaviApiPoller(
|
||||
return channelFlow {
|
||||
while (!isClosedForSend && isPollingExternalConditionSatisfied()) {
|
||||
onPollCallback.invoke()
|
||||
send(onPollExecute.invoke())
|
||||
trySend(onPollExecute.invoke())
|
||||
delay(duration = repeatInterval)
|
||||
currentCount.getAndAdd(1)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user