RxCocoa & RxTest: Rename Element to ElementType

This commit is contained in:
freak4pc 2019-04-22 23:12:28 +03:00 committed by Krunoslav Zaher
parent e48fad5b39
commit 2b8c1a974c
6 changed files with 10 additions and 16 deletions

View File

@ -290,16 +290,16 @@ Observer that enforces interface binding rules:
queue.
*/
@available(*, deprecated, renamed: "Binder")
public final class UIBindingObserver<UIElementType, Value> : ObserverType where UIElementType: AnyObject {
public final class UIBindingObserver<UIElement, Value> : ObserverType where UIElement: AnyObject {
public typealias Element = Value
weak var UIElement: UIElementType?
weak var UIElement: UIElement?
let binding: (UIElementType, Value) -> Void
let binding: (UIElement, Value) -> Void
/// Initializes `ViewBindingObserver` using
@available(*, deprecated, renamed: "UIBinder.init(_:scheduler:binding:)")
public init(UIElement: UIElementType, binding: @escaping (UIElementType, Value) -> Void) {
public init(UIElement: UIElement, binding: @escaping (UIElement, Value) -> Void) {
self.UIElement = UIElement
self.binding = binding
}

View File

@ -9,10 +9,8 @@
import RxSwift
/// Observer that records events together with virtual time when they were received.
public final class TestableObserver<ElementType>
public final class TestableObserver<Element>
: ObserverType {
public typealias Element = ElementType
fileprivate let _scheduler: TestScheduler
/// Recorded events.

View File

@ -10,7 +10,7 @@ import RxSwift
import XCTest
import Dispatch
final class BackgroundThreadPrimitiveHotObservable<ElementType: Equatable> : PrimitiveHotObservable<ElementType> {
final class BackgroundThreadPrimitiveHotObservable<Element: Equatable> : PrimitiveHotObservable<Element> {
override func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
XCTAssertTrue(!DispatchQueue.isMain)
return super.subscribe(observer)

View File

@ -10,7 +10,7 @@ import RxSwift
import XCTest
import Dispatch
final class MainThreadPrimitiveHotObservable<ElementType: Equatable> : PrimitiveHotObservable<ElementType> {
final class MainThreadPrimitiveHotObservable<Element: Equatable> : PrimitiveHotObservable<Element> {
override func subscribe<O : ObserverType>(_ observer: O) -> Disposable where O.Element == Element {
XCTAssertTrue(DispatchQueue.isMain)
return super.subscribe(observer)

View File

@ -13,14 +13,12 @@ import Dispatch
let SubscribedToHotObservable = Subscription(0)
let UnsunscribedFromHotObservable = Subscription(0, 0)
class PrimitiveHotObservable<ElementType> : ObservableType {
typealias Element = ElementType
class PrimitiveHotObservable<Element> : ObservableType {
typealias Events = Recorded<Element>
typealias Observer = AnyObserver<Element>
var _subscriptions = [Subscription]()
let _observers = PublishSubject<ElementType>()
let _observers = PublishSubject<Element>()
public var subscriptions: [Subscription] {
lock.lock()

View File

@ -9,9 +9,7 @@
import RxSwift
import RxTest
final class PrimitiveMockObserver<ElementType> : ObserverType {
typealias Element = ElementType
final class PrimitiveMockObserver<Element> : ObserverType {
private let _events = Synchronized([Recorded<Event<Element>>]())
var events: [Recorded<Event<Element>>] {