mirror of
https://github.com/ReactiveX/RxSwift.git
synced 2024-10-05 06:27:29 +03:00
Tests: Rename O to Observer when applicable
This commit is contained in:
parent
05e27bc13b
commit
1dbb9343a7
@ -11,7 +11,7 @@ import XCTest
|
||||
import Dispatch
|
||||
|
||||
final class BackgroundThreadPrimitiveHotObservable<Element: Equatable> : PrimitiveHotObservable<Element> {
|
||||
override func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
|
||||
override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
|
||||
XCTAssertTrue(!DispatchQueue.isMain)
|
||||
return super.subscribe(observer)
|
||||
}
|
||||
|
@ -11,7 +11,7 @@ import XCTest
|
||||
import Dispatch
|
||||
|
||||
final class MainThreadPrimitiveHotObservable<Element: Equatable> : PrimitiveHotObservable<Element> {
|
||||
override func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
|
||||
override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
|
||||
XCTAssertTrue(DispatchQueue.isMain)
|
||||
return super.subscribe(observer)
|
||||
}
|
||||
|
@ -39,7 +39,7 @@ final class MySubject<Element> : SubjectType, ObserverType where Element : Hasha
|
||||
}
|
||||
}
|
||||
|
||||
func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
|
||||
func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
|
||||
_subscribeCount += 1
|
||||
_observer = AnyObserver(observer)
|
||||
|
||||
|
@ -37,7 +37,7 @@ class PrimitiveHotObservable<Element> : ObservableType {
|
||||
_observers.on(event)
|
||||
}
|
||||
|
||||
func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
|
||||
func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
|
||||
lock.lock()
|
||||
defer { lock.unlock() }
|
||||
|
||||
|
@ -21,7 +21,7 @@ final class TestConnectableObservable<Subject: SubjectType> : ConnectableObserva
|
||||
return _o.connect()
|
||||
}
|
||||
|
||||
func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
|
||||
func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
|
||||
return _o.subscribe(observer)
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user