def _each_item next_token, limit, options = {}, &block
options[:domain] = workflow_execution.domain.name
options[:execution] = {
:workflow_id => workflow_execution.workflow_id,
:run_id => workflow_execution.run_id,
}
options[:maximum_page_size] = limit if limit
options[:next_page_token] = next_token if next_token
options[:reverse_order] = @reverse_order unless
options.has_key?(:reverse_order)
response = client.get_workflow_execution_history(options)
response.data['events'].each do |desc|
event = HistoryEvent.new(workflow_execution, desc)
yield(event)
end
response.data['nextPageToken']
end