Mathieu-Gosbee-ConnectedLab

import Foundation
import RxSwift
public enum SerialQueueState {
    case active
    case idle
}

class SerialQueueSubject<T>: ObservableType where T: ObservableType {
    public var state: Observable<SerialQueueState> {
        return Observable.combineLatest(self.active, self.list)