mirror of
https://github.com/ReactiveX/RxSwift.git
synced 2024-10-05 06:27:29 +03:00
20 lines
684 B
Swift
20 lines
684 B
Swift
//
|
|
// ObservableConvertibleType+Blocking.swift
|
|
// RxBlocking
|
|
//
|
|
// Created by Krunoslav Zaher on 7/12/15.
|
|
// Copyright © 2015 Krunoslav Zaher. All rights reserved.
|
|
//
|
|
|
|
import RxSwift
|
|
|
|
extension ObservableConvertibleType {
|
|
/// Converts an Observable into a `BlockingObservable` (an Observable with blocking operators).
|
|
///
|
|
/// - parameter timeout: Maximal time interval BlockingObservable can block without throwing `RxError.timeout`.
|
|
/// - returns: `BlockingObservable` version of `self`
|
|
public func toBlocking(timeout: RxTimeInterval? = nil) -> BlockingObservable<E> {
|
|
return BlockingObservable(timeout: timeout, source: self.asObservable())
|
|
}
|
|
}
|