dangthaison91

let originalObservable = getObservable()

let defaultValueIfIdle = Observable<Int>.interval(5, scheduler: SerialDispatchQueueScheduler(qos: .background))
    .mapTo("defaultValue")

let observableWithDefaultValue = originalObservable
    .flatMapLatest { item in
        let currentItem = Observable.just(item)
        return Observable.of(currentItem, defaultValueIfIdle).concat()

dangthaison91

let originalObservable = getObservable().share()

let defaultValueIfIdle = Observable<Int>.interval(5, scheduler: SerialDispatchQueueScheduler(qos: .background))
	.mapTo(“defaultValue”)

let observableWithDefaultValue = originalObservable
	.flatMapLatest { item in
		return Observable.of(.just(item), defaultValueIfIdle).concat()
	}

dangthaison91

1. let originalObservable = getObservable().share()

2. let defaultValueAfterFiveSeconds = originalObservable.flatMapLatest { item in
		return Observable<Int>.interval(5, scheduler: SerialDispatchQueueScheduler(qos: .background))
			.mapTo(“defaultValue”)
	}
3. let initialDefaultValue = defaultValueIfIdle.takeUntil(originalObservable)
   let finalOutput = Observable.merge(originalObservable, defaultValueAfterFiveSeconds, initialDefaultValue)

dangthaison91

let output = Observable.merge(initialDefaultValue, observableWithDefaultValue)

// OR

let output = Observable.merge(defaultValueIfIdle.takeUntil(originalObservable), observableWithDefaultValue)

//

dangthaison91

let initialDefaultValue = defaultValueIfIdle.takeUntil(originalObservable)

//

dangthaison91

//
//  Plugin.swift
//
//

import RIBs
import RxSwift

// MARK: - Plugin

dangthaison91

//
//  Plugin.swift
//
//

import RIBs
import RxSwift

// MARK: - Plugin

dangthaison91

//
public protocol ScannerPlugin {
    var id: String { get }

    var symbol: Barcode.Format { get }
    
    func isApplicable(for code: Barcode) -> Observable<Bool>
    
    func build(withCode code: Barcode, listener: ScannerPluginListener) -> ViewableRouting

dangthaison91

extension OSLog {
    static let log = OSLog(subsystem: "", category: "Log")
}

extension UIViewController {
    public class func swizzleTracing() {
        
        // make sure this isn't a subclass
        if self !== UIViewController.self {
            return

dangthaison91

# React Native Android

maven_aar(
    name = "com_facebook_react_native",
    artifact = "com.facebook.react:react-native:0.55.4",
    settings = "//build:settings.xml",
    deps = [
        "@androidsdk//com.android.support:appcompat-v7-25.0.0",
        "@com_facebook_fbui_textlayoutbuilder//aar",
        "@com_facebook_fresco_fresco//aar",