AsyncSequence

public extension AsyncSequence
  • Convert an AsyncSequence to an Observable.

    Iteration runs in a detached task to prevent blocking the calling thread. Use .observe(on:) to control event delivery (e.g., MainScheduler.instance for UI updates).

    Declaration

    Swift

    func asObservable(priority: TaskPriority? = nil) -> Observable<Element>

    Parameters

    priority

    Priority for the detached task

    Return Value

    An Observable of the async sequence’s element type