send should insert (#36)

FigureTechnologies · Nov 11, 2022 · 1e1ea8e · 1e1ea8e
1 parent 9d3a38d
commit 1e1ea8e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...oroutines-retry/src/main/kotlin/tech/figure/coroutines/retry/flow/ObjectStoreRetryFlow.kt b/...oroutines-retry/src/main/kotlin/tech/figure/coroutines/retry/flow/ObjectStoreRetryFlow.kt
@@ -43,7 +43,7 @@ internal open class RecordStoreFlowRetry<T>(
             .asFlow()
 
     override suspend fun send(item: T, e: Throwable) =
-        store.update(item, e)
+        store.insert(item, e)
 
     override suspend fun onSuccess(item: RetryRecord<T>) =
         store.remove(item.data)