Skip to content

Commit 24a013c

Browse files
committed
fix: Pager delay not working
Closes #52
1 parent d4f0198 commit 24a013c

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

Sources/ComposableRequest/Publishers/Pager/Pager.swift

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,8 +99,10 @@ public extension Publishers {
9999
case let delay:
100100
return current
101101
.append(
102-
Deferred { Pager(count - 1, offset: next, delay: self.delay, generator: generator) }
102+
Just(())
103+
.setFailureType(to: Failure.self)
103104
.delay(for: delay, scheduler: RunLoop.main)
105+
.flatMap { _ in Pager(count - 1, offset: next, delay: delay, generator: generator) }
104106
)
105107
.eraseToAnyPublisher()
106108
}

0 commit comments

Comments
 (0)