eunjin3786

let subject = PublishSubject<String>()

subject.onNext("Is anyone listening?")


let subcription1 = subject.subscribe { event in
    print("1) \(event)")
}

let subcription2 = subject.subscribe { event in

eunjin3786

let subject = PassthroughSubject<String, Error>()
subject.send("Is anyone listening?")

let subcription1 = subject.sink(receiveCompletion: {
    print("1) \($0)")
}, receiveValue: {
    print("1) \($0)")
})

let subscription2 = subject.sink(receiveCompletion: {

eunjin3786

let subject = BehaviorSubject<String>.init(value: "Init Value")

subject.onNext("Is anyone listening?")

let subcription1 = subject.subscribe { event in
    print("1) \(event)")
}

let subcription2 = subject.subscribe { event in
    print("2) \(event)")

eunjin3786

let subject = CurrentValueSubject<String, Error>.init("Init Value")

subject.send("Is anyone listening?")

let subcription1 = subject.sink(receiveCompletion: {
    print("1) \($0)")
}, receiveValue: {
    print("1) \($0)")
})

eunjin3786

  [1,2,3,4,5].toObservable()
      .subscribeOn(MainScheduler.instance)
      .doOnNext {
          UIApplication.sharedApplication().networkActivityIndicatorVisible = true
      }  
      .observeOn(backgroundScheduler)
      .flatMapLatest {
          HTTPBinDefaultAPI.sharedAPI.get($0)
      }       
      .observeOn(MainScheduler.instance)

eunjin3786

let jsonPublisher = MyJSONLoaderPublisher() // Some publisher.
let labelUpdater = MyLabelUpdateSubscriber() // Some subscriber that updates UI

jsonPublisher
    .subscribe(on: backgroundQueue)
    .receiveOn(on: RunLoop.main)
    .subscribe(labelUpdater)


// 출처 : https://developer.apple.com/documentation/combine/publishers/prefixuntiloutput/3210286-receive?changes=_4_2

eunjin3786

let backgroundScheduler = SerialDispatchQueueScheduler(qos: .background)

Observable.just(1)
    .map { _ in
        print(Thread.isMainThread)     // false
    }
    .subscribeOn(backgroundScheduler)
    .map { _ in
        print(Thread.isMainThread)     // false
    }

eunjin3786

let backgroundQueue = DispatchQueue.global(qos: .background)

Publishers.Just(1)
    .map { _ in
        print(Thread.isMainThread) // true
    }
    .subscribe(on: backgroundQueue) 
    .map { _ in
        print(Thread.isMainThread) // false
    }.sink {

eunjin3786

Publishers.Just(1)
    .subscribe(on: backgroundQueue)
    .map { _ in
        print(Thread.isMainThread) // false
    }
    .map { _ in
        print(Thread.isMainThread)  // false
    }.sink {
        print(Thread.isMainThread)  // false 

eunjin3786

let stream = Publishers.Just("is Alive?")
    .delay(for: .seconds(5), scheduler: RunLoop.main)
    .sink(receiveCompletion: { (completion) in
        switch completion {
        case .finished: print("finished")
        case .failure(let error): print(error)
        }
    }, receiveValue: {
        print($0)
    })