// 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.Linq; using System.Reactive.Linq; using Microsoft.Reactive.Testing; using ReactiveTests.Dummies; using Xunit; namespace ReactiveTests.Tests { public class SingleTest : ReactiveTest { [Fact] public void Single_ArgumentChecking() { ReactiveAssert.Throws(() => Observable.Single(default(IObservable))); ReactiveAssert.Throws(() => Observable.Single(default(IObservable), _ => true)); ReactiveAssert.Throws(() => Observable.Single(DummyObservable.Instance, default)); } [Fact] public void Single_Empty() { ReactiveAssert.Throws(() => Observable.Empty().Single()); } [Fact] public void SinglePredicate_Empty() { ReactiveAssert.Throws(() => Observable.Empty().Single(_ => true)); } [Fact] public void Single_Return() { var value = 42; Assert.Equal(value, Observable.Return(value).Single()); } [Fact] public void Single_Throw() { var ex = new Exception(); var xs = Observable.Throw(ex); ReactiveAssert.Throws(ex, () => xs.Single()); } [Fact] public void Single_Range() { var value = 42; ReactiveAssert.Throws(() => Observable.Range(value, 10).Single()); } [Fact] public void SinglePredicate_Range() { var value = 42; ReactiveAssert.Throws(() => Observable.Range(value, 10).Single(i => i % 2 == 0)); } [Fact] public void SinglePredicate_Range_ReducesToSingle() { var value = 42; Assert.Equal(45, Observable.Range(value, 10).Single(i => i == 45)); } } }