               root: 'users'
             }
 
+            # And something event worthy happens
+            # (only trigger this once initial data has been received)
+            @users.insert {email: 'graham@daventry.com'}, (err, status) ->
+              should.not.exist err
+
           when 'delta'
             {root, oplist} = event
             [{data, operation}] = oplist

      @stream = new Stream mongoWatchPolicy @users

      # Then the receiver should return the expected data
      receiver = (name, event) ->
        should.exist event.timestamp

        switch name

      # When a receiver is registered
      @stream.register {sessionId: 5}, receiver, (err) =>
        should.not.exist err
