mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
Bug Fix Enumerator::Lazy#uniq state for multiple call
* enumerator.c (lazy_uniq_i): create new hash for each calls. [Fix GH-1820] Currently 2.5.0-preview1 :001 > arr = (0..100).lazy.uniq{|i| i % 10} => #<Enumerator::Lazy: #<Enumerator::Lazy: 0..100>:uniq> 2.5.0-preview1 :002 > arr.to_a => [0, 1, 2, 3, 4, 5, 6, 7, 8, 9] 2.5.0-preview1 :003 > arr.to_a => [] Expected arr.to_a to always return same output From: Anmol Chopra <anmolchopra@rocketbox.in> git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@62731 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
3438cfa729
commit
0faf018624
4 changed files with 61 additions and 9 deletions
21
enumerator.c
21
enumerator.c
|
@ -2240,27 +2240,35 @@ lazy_drop_while(VALUE obj)
|
||||||
}
|
}
|
||||||
|
|
||||||
static VALUE
|
static VALUE
|
||||||
lazy_uniq_i(VALUE i, VALUE hash, int argc, const VALUE *argv, VALUE yielder)
|
lazy_uniq_i(VALUE i, int argc, const VALUE *argv, VALUE yielder)
|
||||||
{
|
{
|
||||||
|
VALUE hash;
|
||||||
|
|
||||||
|
hash = rb_attr_get(yielder, id_memo);
|
||||||
|
if (NIL_P(hash)) {
|
||||||
|
hash = rb_obj_hide(rb_hash_new());
|
||||||
|
rb_ivar_set(yielder, id_memo, hash);
|
||||||
|
}
|
||||||
|
|
||||||
if (rb_hash_add_new_element(hash, i, Qfalse))
|
if (rb_hash_add_new_element(hash, i, Qfalse))
|
||||||
return Qnil;
|
return Qnil;
|
||||||
return rb_funcallv(yielder, id_yield, argc, argv);
|
return rb_funcallv(yielder, id_yield, argc, argv);
|
||||||
}
|
}
|
||||||
|
|
||||||
static VALUE
|
static VALUE
|
||||||
lazy_uniq_func(RB_BLOCK_CALL_FUNC_ARGLIST(i, hash))
|
lazy_uniq_func(RB_BLOCK_CALL_FUNC_ARGLIST(i, m))
|
||||||
{
|
{
|
||||||
VALUE yielder = (--argc, *argv++);
|
VALUE yielder = (--argc, *argv++);
|
||||||
i = rb_enum_values_pack(argc, argv);
|
i = rb_enum_values_pack(argc, argv);
|
||||||
return lazy_uniq_i(i, hash, argc, argv, yielder);
|
return lazy_uniq_i(i, argc, argv, yielder);
|
||||||
}
|
}
|
||||||
|
|
||||||
static VALUE
|
static VALUE
|
||||||
lazy_uniq_iter(RB_BLOCK_CALL_FUNC_ARGLIST(i, hash))
|
lazy_uniq_iter(RB_BLOCK_CALL_FUNC_ARGLIST(i, m))
|
||||||
{
|
{
|
||||||
VALUE yielder = (--argc, *argv++);
|
VALUE yielder = (--argc, *argv++);
|
||||||
i = rb_yield_values2(argc, argv);
|
i = rb_yield_values2(argc, argv);
|
||||||
return lazy_uniq_i(i, hash, argc, argv, yielder);
|
return lazy_uniq_i(i, argc, argv, yielder);
|
||||||
}
|
}
|
||||||
|
|
||||||
static VALUE
|
static VALUE
|
||||||
|
@ -2268,9 +2276,8 @@ lazy_uniq(VALUE obj)
|
||||||
{
|
{
|
||||||
rb_block_call_func *const func =
|
rb_block_call_func *const func =
|
||||||
rb_block_given_p() ? lazy_uniq_iter : lazy_uniq_func;
|
rb_block_given_p() ? lazy_uniq_iter : lazy_uniq_func;
|
||||||
VALUE hash = rb_obj_hide(rb_hash_new());
|
|
||||||
return lazy_set_method(rb_block_call(rb_cLazy, id_new, 1, &obj,
|
return lazy_set_method(rb_block_call(rb_cLazy, id_new, 1, &obj,
|
||||||
func, hash),
|
func, 0),
|
||||||
0, 0);
|
0, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -3,6 +3,26 @@ require_relative 'fixtures/classes'
|
||||||
|
|
||||||
ruby_version_is '2.4' do
|
ruby_version_is '2.4' do
|
||||||
describe 'Enumerator::Lazy#uniq' do
|
describe 'Enumerator::Lazy#uniq' do
|
||||||
|
context 'without block' do
|
||||||
|
before :each do
|
||||||
|
@lazy = [0, 1, 0, 1].to_enum.lazy.uniq
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'returns a lazy enumerator' do
|
||||||
|
@lazy.should be_an_instance_of(Enumerator::Lazy)
|
||||||
|
@lazy.force.should == [0, 1]
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'return same value after rewind' do
|
||||||
|
@lazy.force.should == [0, 1]
|
||||||
|
@lazy.force.should == [0, 1]
|
||||||
|
end
|
||||||
|
|
||||||
|
it 'sets the size to nil' do
|
||||||
|
@lazy.size.should == nil
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
context 'when yielded with an argument' do
|
context 'when yielded with an argument' do
|
||||||
before :each do
|
before :each do
|
||||||
@lazy = [0, 1, 2, 3].to_enum.lazy.uniq(&:even?)
|
@lazy = [0, 1, 2, 3].to_enum.lazy.uniq(&:even?)
|
||||||
|
@ -13,6 +33,11 @@ ruby_version_is '2.4' do
|
||||||
@lazy.force.should == [0, 1]
|
@lazy.force.should == [0, 1]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
it 'return same value after rewind' do
|
||||||
|
@lazy.force.should == [0, 1]
|
||||||
|
@lazy.force.should == [0, 1]
|
||||||
|
end
|
||||||
|
|
||||||
it 'sets the size to nil' do
|
it 'sets the size to nil' do
|
||||||
@lazy.size.should == nil
|
@lazy.size.should == nil
|
||||||
end
|
end
|
||||||
|
@ -31,6 +56,12 @@ ruby_version_is '2.4' do
|
||||||
@lazy = enum.lazy
|
@lazy = enum.lazy
|
||||||
end
|
end
|
||||||
|
|
||||||
|
it 'return same value after rewind' do
|
||||||
|
enum = @lazy.uniq { |_, label| label.downcase }
|
||||||
|
enum.force.should == [[0, 'foo'], [2, 'bar']]
|
||||||
|
enum.force.should == [[0, 'foo'], [2, 'bar']]
|
||||||
|
end
|
||||||
|
|
||||||
it 'returns all yield arguments as an array' do
|
it 'returns all yield arguments as an array' do
|
||||||
@lazy.uniq { |_, label| label.downcase }.force.should == [[0, 'foo'], [2, 'bar']]
|
@lazy.uniq { |_, label| label.downcase }.force.should == [[0, 'foo'], [2, 'bar']]
|
||||||
end
|
end
|
||||||
|
|
|
@ -657,8 +657,13 @@ class TestEnumerator < Test::Unit::TestCase
|
||||||
end
|
end
|
||||||
|
|
||||||
def test_uniq
|
def test_uniq
|
||||||
assert_equal([1, 2, 3, 4, 5, 10],
|
u = [0, 1, 0, 1].to_enum.lazy.uniq
|
||||||
(1..Float::INFINITY).lazy.uniq{|x| (x**2) % 10 }.first(6))
|
assert_equal([0, 1], u.force)
|
||||||
|
assert_equal([0, 1], u.force)
|
||||||
|
|
||||||
|
u = (1..Float::INFINITY).lazy.uniq{|x| (x**2) % 10 }
|
||||||
|
assert_equal([1, 2, 3, 4, 5, 10], u.first(6))
|
||||||
|
assert_equal([1, 2, 3, 4, 5, 10], u.first(6))
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
@ -569,4 +569,13 @@ EOS
|
||||||
[1, 2, 3].lazy.map(&:undefined).map(&:to_s).force
|
[1, 2, 3].lazy.map(&:undefined).map(&:to_s).force
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def test_uniq
|
||||||
|
u = (1..Float::INFINITY).lazy.uniq do |x|
|
||||||
|
raise "too big" if x > 10000
|
||||||
|
(x**2) % 10
|
||||||
|
end
|
||||||
|
assert_equal([1, 2, 3, 4, 5, 10], u.first(6))
|
||||||
|
assert_equal([1, 2, 3, 4, 5, 10], u.first(6))
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue