func confineTo()

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
            }
    }