We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 623abbe commit 6a8f578Copy full SHA for 6a8f578
ft-coroutines-retry/src/main/kotlin/tech/figure/coroutines/retry/flow/ObjectStoreRetryFlow.kt
@@ -17,7 +17,7 @@ fun <T> recordStoreFlowRetry(
17
handler: suspend (T) -> Unit,
18
store: RetryRecordStore<T>,
19
groupSize: Int = 40,
20
-) : FlowRetry<T> = RecordStoreFlowRetry(handler, store, groupSize)
+): FlowRetry<T> = RecordStoreFlowRetry(handler, store, groupSize)
21
22
/**
23
* Retry a flow of objects using the backing [store].
@@ -56,4 +56,4 @@ internal open class RecordStoreFlowRetry<T>(
56
57
override suspend fun hasNext() =
58
!store.isEmpty()
59
-}
+}
0 commit comments