Introductory listener using an observable

5-observable-pattern-intro.js

import {
    BUTTON_DOWN,
    singlePressAction,
} from './actions'

const createButtonObserver = bluetoothAddress => observer => (
    new FlicConnectionChannel(bluetoothAddress)
    .on(
        'buttonUpOrDown',
        buttonPressState => observer.next(buttonPressState)
    )
)

const listenForButtonPress = bluetoothAddress => {
    Rx.Observable
    .create(
        createButtonObserver(bluetoothAddress)
    )
    .filter(buttonState => buttonState === BUTTON_DOWN)
    .subscribe(singlePressAction)
}