RxSwift(18). single

single연산자는 원본 옵저버블에서 첫 요소만 방출하거나 조건과 일치하는 첫 요소만 방출한다.

이름처럼 하나의 요소만 방출하고 두개이상의 요소가 방출될 때는 에러가 발생한다.

let numbers = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

Observable.just(1)
    .single()
    .subscribe{print($0)}
    .disposed(by: disposeBag)

Observable.from(numbers)
    .single()
    .subscribe{print($0)}
    .disposed(by: disposeBag)
    
//next(1)
//completed
//next(1)
//error(Sequence contains more than one element.)

하나의 요소를 방출할때엔 completed로 종료가 된다

여러개의 요소를 방출 할 때엔 하나까지만 방출하고 에러이벤트를 방출한다.(이유와 함께)

 

원본 옵저버블이 요소를 방출하지 않거나, 두개 이상을 방출한다면 에러가 발생한다.

 

single연산자는 두개의 연산자가 존재한다

1. 파라미터가 없는 연산자

 

2. predicate를 받는 연산자

let numbers = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]

Observable.from(numbers)
    .single{ $0 == 3}
    .subscribe{print($0)}
    .disposed(by: disposeBag)
    
//next(3)
//completed

요소엔 3이 한개밖에 없으니 3이 방출되고 completedevent가 방출된다