   context 'get initial state (no data)', ->
     it 'works', (done) ->
       data = [null]
-      data$ = Rx.Observable.from data
+      data$ = Observable.from data
       driver = makeStorageDriver()
       response$ = driver data$
-      response$.toArray().subscribe ([d1, d2]) =>
+      response$.toArray().subscribe (a) =>
+        [d1] = a
+        assert a.length is 1
         assert.deepEqual d1, {}
         assert @getItem.callCount is 0
         assert @setItem.callCount is 0

  context 'get initial state', ->
    it 'works', (done) ->
      data = [null]
      data$ = Rx.Observable.from data
      driver = makeStorageDriver()
      response$ = driver data$
      response$.toArray().subscribe ([d1, d2]) =>
        assert.deepEqual d1, {}
        assert @getItem.callCount is 0
        assert @setItem.callCount is 0

      ,
        baz: 123
      ]
      data$ = Observable.from data
      driver = makeStorageDriver()
      response$ = driver data$
      response$.toArray().subscribe (a) =>
        [d1] = a
        assert a.length is 1 # latest only
        assert.deepEqual d1, baz: 123
        done()
      , done
      null
