htc_4_6.swift

import RxCocoa
import RxSwift
import RxTest
open class TestStore<State: Core.State, Event>: Store<State, Event> where State.Event == Event {
    
    private let observer: TestableObserver<State>
    private let scheduler: TestScheduler
    private let disposeBag: DisposeBag
    
    public init(scheduler: TestScheduler,
                disposeBag: DisposeBag,
                initial: State,
                feedBacks: [SideEffect<State, Event>]) {
        
        self.scheduler = scheduler
        self.disposeBag = disposeBag
        self.observer = scheduler.createObserver(State.self)
        super.init(initial: initial, feedBacks: feedBacks, reducer: State.reduce, scheduler: scheduler)
        
        stateBus
            .distinctUntilChanged()
            .drive(observer)
            .disposed(by: disposeBag)
    }
    
    public func start(with events: [Recorded<RxSwift.Event<Event>>] = []) -> [Recorded<RxSwift.Event<State>>] {
        scheduler
            .createColdObservable(events)
            .bind(to: eventBus)
            .disposed(by: disposeBag)
        scheduler.start()
        return observer.events
    }
    public func start(with events: [Event] = []) -> [State] {
        start(
            with: events
                .enumerated()
                .map { .next(($0.offset), $0.element) }
        )
            .compactMap(\.value.element)
    }
}