in RIBs/Classes/Interactor.swift [166:177]
func confineTo(_ interactorScope: InteractorScope) -> Observable<Element> {
return Observable
.combineLatest(interactorScope.isActiveStream, self) { isActive, value in
(isActive, value)
}
.filter { isActive, value in
isActive
}
.map { isActive, value in
value
}
}