RxSwift/RxTests/RxSwiftTests/TestImplementations/Mocks/MainThreadPrimitiveHotObservable.swift

//
//  MainThreadPrimitiveHotObservable.swift
//  RxTests
//
//  Created by Krunoslav Zaher on 10/14/15.
//
//

import Foundation
import RxSwift
import XCTest

class MainThreadPrimitiveHotObservable<ElementType: Equatable> : PrimitiveHotObservable<ElementType> {
    override func subscribe<O : ObserverType where O.E == E>(observer: O) -> Disposable {
        XCTAssertTrue(NSThread.isMainThread())
        return super.subscribe(observer)
    }
}