let source : Observable<Int> = Observable.create { observer in
    for i in 1...5 {
        observer.on(.next(i))
    }
    observer.on(.completed)
    return Disposables.create {
        print("disposed")
    }
}
_ = source.subscribe { event in
    print(event)
}