Function TestChannelIterator

iterator/iterator_test.go:160–178

(t *testing.T)

}

func TestChannelIterator(t *testing.T) {
	t.Parallel()

	assert := internal.NewAssert(t, "TestRangeIterator")

	var iter Iterator[int] = FromSlice([]int{1, 2, 3, 4})

	ctx, cancel := context.WithCancel(context.Background())
	iter = FromChannel(ToChannel(ctx, iter, 0))
	item, ok := iter.Next()
	assert.Equal(1, item)
	assert.Equal(true, ok)
	assert.Equal(true, iter.HasNext())

	cancel()

	_, ok = iter.Next()
	assert.Equal(false, ok)
}