         _id: 2
         operation: 'set'
         path: '.'
-        data: { _id: 2, accountId: 1, name: 'Jane' }
+        data: { _id: 2, accountId: 1, name: 'Jane', email: 'jane@foo.com' }
       }
       done()
 

        _id: 1
        operation: 'set'
        path: '.'
        data: { _id: 1, accountId: 1, name: 'Bob' }
      }
      jane.should.include {
        origin: 'end payload'

{EventEmitter} = require 'events'
#{Server, Db, ObjectID} = require 'mongodb'

limit = require './helpers/limit'
{Stream} = require '../'
samplePolicy = require '../sample/data/samplePolicy'

describe 'Stream', ->
  beforeEach ->
