QueryPublisher

Swift

typealias Output = [Item]

Swift

typealias Failure = Never

Swift

let query: String

Swift

let itemEvents: Cache.ItemChange

Swift

let cache: Cache

Swift

let wait: Double

Swift

init(cache: Cache, query: String, events: Cache.ItemChange, wait: Double)

Swift

func receive<S>(subscriber: S) where S: Subscriber,
    S.Failure == QueryPublisher.Failure, S.Input == QueryPublisher.Output