ObservableType

public extension ObservableType

  • An oberverable to execute retry and execute code on reconnect after a timeout timeout

    Declaration

    Swift

    func retryOnConnect(timeout: DispatchTimeInterval) -> Observable<Element>

    Parameters

    timeout

    Seconds for timeout

    Return Value

    An observable sequence with a RxError.timeout in case of a timeout.

    Show on GitHub

  • An filtered oberverable to execute retry and execute code on reconnect after a timeout timeout

    Declaration

    Swift

    func retryOnConnect(
  timeout: DispatchTimeInterval,
  predicate: @escaping (Swift.Error) -> Bool
) -> Observable<Element>

    Parameters

    timeout

    Seconds for timeout
    predicate

    A function to test each source element for a condition.

    Return Value

    An observable sequence producing the elements of the given sequence repeatedly until it terminates successfully or is notified to error or complete.

    Show on GitHub

  • An filtered oberverable to execute retry and execute code on reconnect after a timeout timeout

    Declaration

    Swift

    func retryLatestOnConnect(
  timeout: DispatchTimeInterval,
  predicate: @escaping (Swift.Error) -> Bool
) -> Observable<Element>

    Parameters

    timeout

    Seconds for timeout
    predicate

    A function to test each source element for a condition.

    Return Value

    An observable sequence whose elements are the result of invoking the transform function on each element of source producing an Observable of Observable sequences and that at any point in time produces the elements of the most recent inner observable sequence that has been received.

    Show on GitHub