observable.test.js

import test from 'ava';
import Rx from 'rxjs/Rx';
import {createStore} from 'redux';

test('should be observable', t => {

    const reducer = (state, action) => {
        if (action.type === 'increment') {
            return {...state, counter: state.counter + 1}
        }
        return state;
    };
    const store = createStore(reducer, {counter: 0});

    const results = [];
    Rx.Observable.from(store)
        .distinct()
        .subscribe(state => results.push(state));

    store.dispatch({type: 'increment'});
    store.dispatch({type: 'unknown'});
    store.dispatch({type: 'increment'});

    t.deepEqual(results, [
        {counter: 0},
        {counter: 1},
        {counter: 2}
    ])
});

Super curious of how the internals of this are working. Is it create as an ArrayLikeObservable?