Add Hash support to fetch_all (#586)
This commit aligns the behavior of `fetch_all` over map responses with that of arrays (returning a single collection with all entries).
This commit is contained in:
parent
9237ba59cb
commit
e3792b19d2
|
@ -69,6 +69,12 @@ module Google
|
||||||
break if @max && item_count > @max
|
break if @max && item_count > @max
|
||||||
yield item
|
yield item
|
||||||
end
|
end
|
||||||
|
elsif items.kind_of?(Hash)
|
||||||
|
items.each do |key, val|
|
||||||
|
item_count = item_count + 1
|
||||||
|
break if @max && item_count > @max
|
||||||
|
yield key, val
|
||||||
|
end
|
||||||
elsif items
|
elsif items
|
||||||
# yield singular non-nil items (for genomics API)
|
# yield singular non-nil items (for genomics API)
|
||||||
yield items
|
yield items
|
||||||
|
|
|
@ -313,11 +313,11 @@ EOF
|
||||||
let(:responses) do
|
let(:responses) do
|
||||||
data = {}
|
data = {}
|
||||||
data[nil] = OpenStruct.new(
|
data[nil] = OpenStruct.new(
|
||||||
next_page_token: 'p1', alt_page_token: 'p2', items: ['a', 'b', 'c'], alt_items: [1, 2, 3], singular: 'foo')
|
next_page_token: 'p1', alt_page_token: 'p2', items: ['a', 'b', 'c'], alt_items: [1, 2, 3], singular: 'foo', hash_: { 'foo' => 1, 'bar' => 2 })
|
||||||
data['p1'] = OpenStruct.new(
|
data['p1'] = OpenStruct.new(
|
||||||
next_page_token: 'p2', items: ['d', 'e', 'f'], alt_items: [4, 5, 6], singular: 'bar')
|
next_page_token: 'p2', items: ['d', 'e', 'f'], alt_items: [4, 5, 6], singular: 'bar', hash_: nil)
|
||||||
data['p2'] = OpenStruct.new(
|
data['p2'] = OpenStruct.new(
|
||||||
next_page_token: nil, alt_page_token: nil, items: ['g', 'h', 'i'], alt_items: [7, 8, 9], singular: 'baz')
|
next_page_token: nil, alt_page_token: nil, items: ['g', 'h', 'i'], alt_items: [7, 8, 9], singular: 'baz', hash_: { 'baz' => 3 })
|
||||||
data
|
data
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -350,6 +350,10 @@ EOF
|
||||||
expect(service.fetch_all(items: :singular) { |token| responses[token] } ).to contain_exactly('foo', 'bar', 'baz')
|
expect(service.fetch_all(items: :singular) { |token| responses[token] } ).to contain_exactly('foo', 'bar', 'baz')
|
||||||
end
|
end
|
||||||
|
|
||||||
|
it 'should collate hash entries' do
|
||||||
|
expect(service.fetch_all(items: :hash_) { |token| responses[token] } ).to contain_exactly(['foo', 1], ['bar', 2], ['baz', 3])
|
||||||
|
end
|
||||||
|
|
||||||
it 'should allow limiting the number of items to fetch' do
|
it 'should allow limiting the number of items to fetch' do
|
||||||
expect(service.fetch_all(max: 5) { |token| responses[token] } ).to contain_exactly('a', 'b', 'c', 'd', 'e')
|
expect(service.fetch_all(max: 5) { |token| responses[token] } ).to contain_exactly('a', 'b', 'c', 'd', 'e')
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue