                         streamRevision:1 + @commit1.streamRevision
 
                     verify = es.through (data) =>
-                        console.log 'verifying', data
                         data.streamId.should.equal expect.streamId
                         data.streamRevision.should.equal(expect.streamRevision)
                         done()

                @timeout 10
                storage = eventStore(redis.createStorage(cfg))
                filter =
                    streamId: '123'
                    minRevision: 0
                    maxRevision: Number.MAX_VALUE
                stream = storage.open filter



        describe '#pipe into aggregate', ->
            streamId = 'intoagg'
            beforeEach (done) ->
                @commit1 =
                    checkRevision: 0
                    headers: []
                    streamId: streamId
                    streamRevision: 3
                    payload: [
                        {a:1}
