FlatMap Article - Type Declarations

types.swift

class Project {
    private let developerSubject = PublishSubject<Developer>()
    var developerStream: Observable<Developer> {
        return developerSubject.asObservable()
    }
    
    func addDeveloper(_ developer: Developer) {
        developerSubject.onNext(developer)
    }
    
    func stop() {
        developerSubject.onCompleted()
    }
}

class Developer {
    private let commitSubject = PublishSubject<Commit>()
    let name: String
    
    init(_ name: String) {
        self.name = name
    }
    
    func startCoding() -> Observable<Commit> {
        return commitSubject.asObservable()
    }
    
    func stopCoding() {
        commitSubject.onCompleted()
    }
    
    // Helper to externally simulate coding activity.
    func pushCommit(_ hash: String) {
        commitSubject.onNext(Commit(author: name, hash: hash))
    }
}

struct Commit {
    let author: String
    let hash: String
}

class CI: ObserverType {
    func on(_ event: Event<Commit>) {
        switch event {
        case .next(let commit): print("CI is building \(commit).")
        case .completed: print("CI stopped.")
        case .error(let error): print("CI errored: \(error).")
        }
    }
}