Fix

dydxprotocol · Oct 4, 2024 · c450a70 · c450a70
1 parent 14cc2a5
commit c450a70
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../java/exchange/dydx/trading/feature/workers/globalworkers/DydxTransferSubaccountWorker.kt b/.../java/exchange/dydx/trading/feature/workers/globalworkers/DydxTransferSubaccountWorker.kt
@@ -47,10 +47,10 @@ class DydxTransferSubaccountWorker @Inject constructor(
 
             combine(
                 timerFlow(20.seconds),
-                abacusStateManager.state.accountBalance(abacusStateManager.usdcTokenDenom)
-                    .filterNotNull(),
+                abacusStateManager.state.accountBalance(abacusStateManager.usdcTokenDenom),
                 abacusStateManager.state.currentWallet.mapNotNull { it },
             ) { _, balance, wallet ->
+                val balance = balance ?: 0.0
                 if (balance > balanceRetainAmount) {
                     val depositAmount = balance.minus(balanceRetainAmount)
                     if (depositAmount <= 0) return@combine