QuerySubscription

final class QuerySubscription<SubscriberType: Subscriber>: Subscription
    where SubscriberType.Input == [Item]

Undocumented

  • Undocumented

    Declaration

    Swift

    init(
        cache: Cache,
        subscriber: SubscriberType,
        query: String,
        event: Cache.ItemChange,
        wait: Double
    )
  • Undocumented

    Declaration

    Swift

    func waitListen(_ retries: Int = 0, _ error: Error? = nil)
  • Undocumented

    Declaration

    Swift

    func listen(_ retries: Int = 0, _ error: Error? = nil)
  • Declaration

    Swift

    func request(_: Subscribers.Demand)
  • Declaration

    Swift

    func cancel()