[RxSwift] Filtering Operators

take

take(_ count:) : 해당 갯수만큼만 스트림을 받는다.

take(for: scheduler:) : 해당 초 만큼만 스트림을 받는다.

observable
	.take(10) //10 개만 받음
	.subscribe();

observable
  .take(for: RxTimeInterval.seconds(10), scheduler: MainScheduler.asyncInstance) 
	//10초 만큼만 받는다.
	.subscribe();

take(while: behavior:)

take(while:) : 해당 조건식이 true 일 때까지만 받는다.

behavior

• inclusive - 마지막 요소 포함
• exclusive - 마지막 요소 버림

observable
	.take(while: { $0 != 3 }, behavior: TakeBehavior.exclusive) 
	// 스트림이 3 이 아닐때까지 받는다. 3이면 버린다.
	.subscribe();