Back to Rxswift

ObservableConvertibleType

docs/Protocols/ObservableConvertibleType.html

6.10.22.1 KB
Original Source

ObservableConvertibleType

public protocol ObservableConvertibleType

Type that can be converted to observable sequence (Observable<Element>).

`

                Element
                `

Type of elements in sequence.

Declaration

Swift

associatedtype Element

`

                asObservable()
                `

Converts self to Observable sequence.

Declaration

Swift

func asObservable() -> Observable<Element>

Return Value

Observable sequence that represents self.

`

                values
                ` Extension method 

Allows iterating over the values of an Observable asynchronously via Swift’s concurrency features (async/await)

A sample usage would look like so:

do {
    for try await value in observable.values {
        // Handle emitted values
    }
} catch {
    // Handle error
}

Declaration

Swift

var values: AsyncThrowingStream<Element, Error> { get }

`

                asInfallible(onErrorJustReturn:)
                ` Extension method 

Convert to an Infallible

Declaration

Swift

func asInfallible(onErrorJustReturn element: Element) -> Infallible<Element>

Return Value

Infallible<Element>

`

                asInfallible(onErrorFallbackTo:)
                ` Extension method 

Convert to an Infallible

Declaration

Swift

func asInfallible(onErrorFallbackTo infallible: Infallible<Element>) -> Infallible<Element>

Parameters

| infallible |

Fall back to this provided infallible on error

|

Return Value

Infallible<Element>

`

                asInfallible(onErrorRecover:)
                ` Extension method 

Convert to an Infallible

Declaration

Swift

func asInfallible(onErrorRecover: @escaping (Swift.Error) -> Infallible<Element>) -> Infallible<Element>

Parameters

| onErrorRecover |

Recover with the this infallible closure

|

Return Value

Infallible<Element>