feat(endpoints): support delay between pages

sbertix · sbertix · commit 4e11b0d241b9 · 2021-05-22T12:06:13.000+02:00
diff --git a/Package.swift b/Package.swift
@@ -18,7 +18,7 @@ let package = Package(
                .library(name: "SwiftagramCrypto",
                         targets: ["SwiftagramCrypto"])],
     // Package dependencies.
-    dependencies: [.package(url: "https://github.com/sbertix/ComposableRequest", .upToNextMinor(from: "5.1.0")),
+    dependencies: [.package(url: "https://github.com/sbertix/ComposableRequest", .upToNextMinor(from: "5.2.1")),
                    .package(url: "https://github.com/sbertix/SwCrypt.git", .upToNextMinor(from: "5.1.0"))],
     // All targets.
     targets: [.target(name: "Swiftagram",
diff --git a/Sources/Swiftagram/Endpoints/Recent/Endpoint+Recent.swift b/Sources/Swiftagram/Endpoints/Recent/Endpoint+Recent.swift
@@ -46,7 +46,7 @@ public extension Endpoint.Group.Recent {
             // Persist the rank token.
             let rank = pages.rank ?? UUID().uuidString
             // Prepare the actual pager.
-            return Pager(pages.count, offset: pages.offset.offset) {
+            return Pager(pages.count, offset: pages.offset.offset, delay: pages.delay) {
                 Request.feed
                     .path(appending: "timeline/")
                     .header(appending: secret.header)
diff --git a/Tests/SwiftagramTests/EndpointTests.swift b/Tests/SwiftagramTests/EndpointTests.swift
@@ -21,6 +21,7 @@ import AppKit
 @testable import Swiftagram
 @testable import SwiftagramCrypto
 
+import ComposableRequest
 import SwCrypt
 
 /// The default delay.
diff --git a/docs/README.md b/docs/README.md
@@ -245,9 +245,12 @@ Endpoint.user(secret.identifier)
     .posts
     .unlock(with: secret)
     .session(.instagram)
-    .pages(.max)    // Exhaust all with `.max`
-                    // or pass any `Int` to limit
-                    // pages.
+    .pages(.max, delay: 1)  // Exhaust all with `.max`
+                            // or pass any `Int` to limit
+                            // pages.
+                            // You can omit `delay`, in that
+                            // case pages will be fetched 
+                            // one immediately after the other.
     .sink(receiveCompletion: { _ in }, receiveValue: { print($0) })
     .store(in: &bin)
 ```
