                     pipe.write filter.maxRevision
                     pipe.end()
                 reader
-
-            read: (filter, callback) ->
-                reader = @createReader()
-                events = []
-                reader.on 'error', => 
-                    events = []
-                    callback.apply  @, arguments
-                reader.on 'data', (data) =>
-                    concat events, data
-                reader.on 'end', =>
-                    args = slice.call arguments
-                    args.unshift events
-                    args.unshift null
-                    callback.apply @, args
-                reader.read filter
-
 
             createCommitter: ->
                 emitter = es.map (commit, next) ->

                    ck.end()
                    

            write: (commit, callback) ->
                committer = @createCommitter()
                committer.on 'commit', =>

                    streams = [
                        client.stream('zrangebyscore', id, filter.minRevision)
                        es.parse()
                        finish
                    ]
                    pipe = es.pipeline.apply @, streams
                    #proxy stream commands to our pipe
