Stream

Swift

public struct Subscriber<E> where E : Event

Swift

public init()

Swift

public var current: E { get set }

Swift

public func subscribe(with token: AnyHashable? = nil, on queue: DispatchQueue = .global(), with callback: @escaping (E) -> Void)

Swift

public func subscribeStrong<S: AnyObject>(_ sender: S,
                                          with token: AnyHashable? = nil,
                                          on queue: DispatchQueue = .global(),
                                          with callback: @escaping (S, E) -> Void)

Swift

public func unsubscribe(_ token: AnyHashable)

Swift

public func unsubscribeAll()

Swift

func when(_ condition: @escaping (E) -> Bool) -> Guarantee<()>