diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/fleet/msearch.rb b/elasticsearch-api/lib/elasticsearch/api/actions/fleet/msearch.rb index d7603b304..d80bbed75 100644 --- a/elasticsearch-api/lib/elasticsearch/api/actions/fleet/msearch.rb +++ b/elasticsearch-api/lib/elasticsearch/api/actions/fleet/msearch.rb @@ -60,15 +60,13 @@ def msearch(arguments = {}) params = {} if body.is_a?(Array) && body.any? { |d| d.has_key? :search } - payload = body - .each_with_object([]) do |item, sum| + payload = body.each_with_object([]) do |item, sum| meta = item data = meta.delete(:search) sum << meta sum << data - end - .map { |item| Elasticsearch::API.serializer.dump(item) } + end.map { |item| Elasticsearch::API.serializer.dump(item) } payload << '' unless payload.empty? payload = payload.join("\n") elsif body.is_a?(Array) diff --git a/elasticsearch-api/lib/elasticsearch/api/actions/msearch.rb b/elasticsearch-api/lib/elasticsearch/api/actions/msearch.rb index b46d701c1..687e48a91 100644 --- a/elasticsearch-api/lib/elasticsearch/api/actions/msearch.rb +++ b/elasticsearch-api/lib/elasticsearch/api/actions/msearch.rb @@ -62,15 +62,13 @@ def msearch(arguments = {}) params = Utils.process_params(arguments) if body.is_a?(Array) && body.any? { |d| d.has_key? :search } - payload = body - .each_with_object([]) do |item, sum| + payload = body.each_with_object([]) do |item, sum| meta = item data = meta.delete(:search) sum << meta sum << data - end - .map { |item| Elasticsearch::API.serializer.dump(item) } + end.map { |item| Elasticsearch::API.serializer.dump(item) } payload << '' unless payload.empty? payload = payload.join("\n") elsif body.is_a?(Array)