Publisher

extension Publisher
extension Publisher where Failure == RxBridgeFailure

  • A bridging operator that transforms a Combine Publisher into an RxSwift Observable.

    Declaration

    Swift

    public func bridgeToRx() -> Observable<Output>

    Return Value

    An observable that republishes the elements of an upstream Combine publisher

Available where Failure == RxBridgeFailure

  • Raises a fatal error when an upstream RxBridge publisher’s buffer overflows and otherwise maps the failure type to the Error type of an upstream Observable.

    Use this operator at some point following the RxBridge operator if you can be sure that a buffer overflow will never occur.

    Declaration

    Swift

    public func assertBridgeBufferNeverOverflows() -> Publishers.MapError<Self, Error>

    Return Value

    A publisher with an Failure type that matches the Error type of an upstream bridged Observable