def each_batch
      return to_enum(:each_batch) unless block_given?

      reader.each(in_batches(result.batch_size).result) do |batch|
        yield batch
      end
    end
def each_batch
      return to_enum(:each_batch) unless block_given?

      reader.each(in_batches(result.batch_size).result) do |batch|
        yield batch
      end
    end
Executes the query based on the specification built up to this point.
 Yields each batch of records that was retrieved from the store.
 {http://railseventstore.org/docs/read/ Find out more}.

 @yield [Array<Event, Proto>] batch of events
 @return [Enumerator, nil] Enumerator is returned when block not given