// Licensed to the .NET Foundation under one or more agreements. // The .NET Foundation licenses this file to you under the Apache 2.0 License. // See the LICENSE file in the project root for more information. using System; using System.Collections.Generic; using System.Linq; using System.Threading.Tasks; using Xunit; namespace Tests { public class DefaultIfEmpty : AsyncEnumerableTests { [Fact] public void DefaultIfEmpty_Null() { Assert.Throws(() => AsyncEnumerable.DefaultIfEmpty(default)); Assert.Throws(() => AsyncEnumerable.DefaultIfEmpty(default, 42)); } [Fact] public async Task DefaultIfEmpty1() { var xs = AsyncEnumerable.Empty().DefaultIfEmpty(); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 0); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty2() { var xs = AsyncEnumerable.Empty().DefaultIfEmpty(42); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 42); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty3() { var xs = Return42.DefaultIfEmpty(); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 42); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty4() { var xs = Return42.DefaultIfEmpty(24); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 42); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty5() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 1); await HasNextAsync(e, 2); await HasNextAsync(e, 3); await HasNextAsync(e, 4); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty6() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(24); var e = xs.GetAsyncEnumerator(); await HasNextAsync(e, 1); await HasNextAsync(e, 2); await HasNextAsync(e, 3); await HasNextAsync(e, 4); await NoNextAsync(e); } [Fact] public async Task DefaultIfEmpty7Async() { var ex = new Exception("Bang!"); var xs = Throw(ex).DefaultIfEmpty(); var e = xs.GetAsyncEnumerator(); await AssertThrowsAsync(e.MoveNextAsync(), ex); } [Fact] public async Task DefaultIfEmpty8Async() { var ex = new Exception("Bang!"); var xs = Throw(ex).DefaultIfEmpty(24); var e = xs.GetAsyncEnumerator(); await AssertThrowsAsync(e.MoveNextAsync(), ex); } [Fact] public async Task DefaultIfEmpty9() { var xs = AsyncEnumerable.Empty().DefaultIfEmpty(42); var res = new[] { 42 }; Assert.True(res.SequenceEqual(await xs.ToArrayAsync())); } [Fact] public async Task DefaultIfEmpty10() { var xs = AsyncEnumerable.Empty().DefaultIfEmpty(42); var res = new List { 42 }; Assert.True(res.SequenceEqual(await xs.ToListAsync())); } [Fact] public async Task DefaultIfEmpty11() { var xs = AsyncEnumerable.Empty().DefaultIfEmpty(42); Assert.Equal(1, await xs.CountAsync()); } [Fact] public async Task DefaultIfEmpty12() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(24); var res = new[] { 1, 2, 3, 4 }; Assert.True(res.SequenceEqual(await xs.ToArrayAsync())); } [Fact] public async Task DefaultIfEmpty13() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(24); var res = new List { 1, 2, 3, 4 }; Assert.True(res.SequenceEqual(await xs.ToListAsync())); } [Fact] public async Task DefaultIfEmpty14() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(24); Assert.Equal(4, await xs.CountAsync()); } [Fact] public async Task DefaultIfEmpty15() { var xs = new[] { 1, 2, 3, 4 }.ToAsyncEnumerable().DefaultIfEmpty(24); await SequenceIdentity(xs); } } }