Skip to content

Merge Funcky.Async into Funcky (#851) #869

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
csillikd-messerli wants to merge 2 commits into from
Closed

Merge Funcky.Async into Funcky (#851) #869

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
9f567ec
Merge Funcky.Async into Funcky
csillikd-messerli Jan 7, 2026
5ca7f4a
Rename namespaces
csillikd-messerli Jan 7, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 0 additions & 11 deletions Funcky.Async.Test/TestUtilities/CountCreation.cs
View file
Open in desktop

This file was deleted.

18 changes: 0 additions & 18 deletions Funcky.Async.Test/TestUtilities/FailOnCall.cs
View file
Open in desktop

This file was deleted.

278 changes: 0 additions & 278 deletions Funcky.Async/PublicAPI.Shipped.txt
View file
Open in desktop

Large diffs are not rendered by default.

4 changes: 0 additions & 4 deletions Funcky.Async/PublicAPI.Unshipped.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1 @@
#nullable enable
static Funcky.Extensions.AsyncEnumerableExtensions.Traverse<TSource, T>(this System.Collections.Generic.IAsyncEnumerable<TSource>! source, System.Func<TSource, System.Lazy<T>!>! selector) -> System.Lazy<System.Collections.Generic.IAsyncEnumerable<T>!>!
static Funcky.Extensions.AsyncEnumerableExtensions.WhereSelect<TSource, TResult>(this System.Collections.Generic.IAsyncEnumerable<TSource>! source, System.Func<TSource, int, Funcky.Monads.Option<TResult>>! selector) -> System.Collections.Generic.IAsyncEnumerable<TResult>!
static Funcky.Extensions.AsyncEnumerableExtensions.WhereSelectAwait<TSource, TResult>(this System.Collections.Generic.IAsyncEnumerable<TSource>! source, System.Func<TSource, int, System.Threading.Tasks.ValueTask<Funcky.Monads.Option<TResult>>>! selector) -> System.Collections.Generic.IAsyncEnumerable<TResult>!
static Funcky.Extensions.AsyncEnumerableExtensions.WhereSelectAwaitWithCancellation<TSource, TResult>(this System.Collections.Generic.IAsyncEnumerable<TSource>! source, System.Func<TSource, int, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask<Funcky.Monads.Option<TResult>>>! selector) -> System.Collections.Generic.IAsyncEnumerable<TResult>!
6 changes: 5 additions & 1 deletion Funcky.Async.Test/AsyncGenerator.cs → Funcky.Test/AsyncGenerator.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,9 @@
#if !NET48

using FsCheck;
using FsCheck.Fluent;

namespace Funcky.Async.Test;
namespace Funcky.Test;

internal static class AsyncGenerator
{
Expand All @@ -24,3 +26,5 @@ private static AwaitSelectorWithCancellation<T> ResultToValueTaskX<T>(Func<T, T>
public sealed record AwaitSelector<T>(Func<T, ValueTask<T>> Get);

public sealed record AwaitSelectorWithCancellation<T>(Func<T, CancellationToken, ValueTask<T>> Get);

#endif
6 changes: 3 additions & 3 deletions ...ky.Async.Test/AsyncSequence/ConcatTest.cs → .../AsyncSequence/ConcatAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,11 @@
using FsCheck;
using FsCheck.Fluent;
using FsCheck.Xunit;
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test;
namespace Funcky.Test;

public sealed class ConcatTest
public sealed class ConcatAsyncSequenceTest
{
[Fact]
public async Task ConcatenatedSequenceIsEmptyWhenNoSourcesAreProvidedAsync()
Expand Down
4 changes: 2 additions & 2 deletions Funcky.Async.Test/AsyncSequence/CycleTest.cs → ...t/AsyncSequence/CycleAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
using FsCheck.Xunit;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test;
namespace Funcky.Test;

public sealed class CycleTest
public sealed class CycleAsyncSequenceTest
{
[Property]
public Property CycleCanProduceArbitraryManyItems(int value, PositiveInt arbitraryElements)
Expand Down
9 changes: 6 additions & 3 deletions ...sync.Test/AsyncSequence/CycleRangeTest.cs → ...ncSequence/CycleRangeAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,12 +1,13 @@
#if !NET48

using FsCheck;
using FsCheck.Fluent;
using FsCheck.Xunit;
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test;
namespace Funcky.Test;

public sealed class CycleRangeTest
public sealed class CycleRangeAsyncSequenceTest
{
[Fact]
public async Task CycleRangeIsEnumeratedLazilyAsync()
Expand Down Expand Up @@ -67,3 +68,5 @@ private async Task<bool> CycleRangeRepeatsTheElementsArbitraryManyTimesAsync(IAs
.NTimes(arbitraryElements);
}
}

#endif
9 changes: 6 additions & 3 deletions ...ync.Test/AsyncSequence/RepeatRangeTest.cs → ...cSequence/RepeatRangeAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,12 +1,13 @@
#if !NET48

using FsCheck;
using FsCheck.Fluent;
using FsCheck.Xunit;
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test;
namespace Funcky.Test;

public sealed class RepeatRangeTest
public sealed class RepeatRangeAsyncSequenceTest
{
[Fact]
public async Task RepeatRangeIsEnumeratedLazily()
Expand Down Expand Up @@ -95,3 +96,5 @@ private static async Task<bool> TheSequenceRepeatsTheGivenNumberOfTimesAsync(IAs
.NTimes(count);
}
}

#endif
6 changes: 3 additions & 3 deletions ...ky.Async.Test/AsyncSequence/ReturnTest.cs → .../AsyncSequence/ReturnAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
using FsCheck;
using FsCheck.Fluent;
using FsCheck.Xunit;
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test;
namespace Funcky.Test;

public sealed class ReturnTest
public sealed class ReturnAsyncSequenceTest
{
[Property]
public Property ReturnOfASingleItemElevatesThatItemIntoASingleItemedEnumerable(int item)
Expand Down
10 changes: 7 additions & 3 deletions ...sync.Test/AsyncSequence/SuccessorsTest.cs → ...ncSequence/SuccessorsAsyncSequenceTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,10 @@
using Funcky.Async.Test.TestUtilities;
#if !NET48

namespace Funcky.Async.Test;
using Funcky.Test.TestUtils;

public sealed class SuccessorsTest
namespace Funcky.Test;

public sealed class SuccessorsAsyncSequenceTest
{
[Fact]
public async Task ReturnsEmptySequenceWhenFirstItemIsNoneAsync()
Expand Down Expand Up @@ -40,3 +42,5 @@ await AsyncAssert.Equal(
AsyncSequence.Successors(0, i => ValueTask.FromResult(Option.FromBoolean(i < 10, i + 1))));
}
}

#endif
4 changes: 2 additions & 2 deletions ...umerableExtensions/AdjacentGroupByTest.cs → ...umerableExtensions/AdjacentGroupByTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class AdjacentGroupByTest
{
Expand Down
4 changes: 2 additions & 2 deletions ...syncEnumerableExtensions/AnyOrElseTest.cs → ...syncEnumerableExtensions/AnyOrElseTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class AnyOrElseTest
{
Expand Down
6 changes: 5 additions & 1 deletion ...EnumerableExtensions/AverageOrNoneTest.cs → ...EnumerableExtensions/AverageOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,9 +1,11 @@
#if !NET48

// ReSharper disable PossibleMultipleEnumeration
using FsCheck;
using FsCheck.Fluent;
using Funcky.Test.Internal;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class AverageOrNoneTest
{
Expand Down Expand Up @@ -157,3 +159,5 @@ private static async Task<bool> CompareAverageAndHandleEmptyDecimalSequenceAsync
? await sequence.AverageAsync() == await sequence.AverageOrNoneAsync()
: (await sequence.AverageOrNoneAsync()).Match(none: true, some: _ => false);
}

#endif
4 changes: 2 additions & 2 deletions ...ns/AsyncEnumerableExtensions/ChunkTest.cs → ...ns/AsyncEnumerableExtensions/ChunkTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class ChunkTest
{
Expand Down
2 changes: 1 addition & 1 deletion ...numerableExtensions/ConcatToStringTest.cs → ...numerableExtensions/ConcatToStringTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public class ConcatToStringTest
{
Expand Down
8 changes: 6 additions & 2 deletions ...umerableExtensions/ElementAtOrNoneTest.cs → ...umerableExtensions/ElementAtOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,9 +1,11 @@
#if !NET48

using FsCheck;
using FsCheck.Fluent;
using Funcky.FsCheck;
using static Funcky.Async.Test.Extensions.AsyncEnumerableExtensions.TestData;
using static Funcky.Test.Extensions.AsyncEnumerableExtensions.TestData;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class ElementAtOrNoneTest
{
Expand Down Expand Up @@ -39,3 +41,5 @@ public Property BehavesIdenticalToSynchronousCounterpart(List<int> source, Index
.ToProperty();
}
}

#endif
4 changes: 2 additions & 2 deletions ...ncEnumerableExtensions/FirstOrNoneTest.cs → ...ncEnumerableExtensions/FirstOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using static Funcky.Async.Test.Extensions.AsyncEnumerableExtensions.TestData;
using static Funcky.Test.Extensions.AsyncEnumerableExtensions.TestData;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class FirstOrNoneTest
{
Expand Down
4 changes: 2 additions & 2 deletions ...cEnumerableExtensions/InspectEmptyTest.cs → ...cEnumerableExtensions/InspectEmptyTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class InspectEmptyTest
{
Expand Down
8 changes: 6 additions & 2 deletions .../AsyncEnumerableExtensions/InspectTest.cs → .../AsyncEnumerableExtensions/InspectTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
using Funcky.Async.Test.TestUtilities;
#if !NET48

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
using Funcky.Test.TestUtils;

namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class InspectTest
{
Expand Down Expand Up @@ -70,3 +72,5 @@ public async Task CancellationIsPropagatedInAwaitOverload()
_ = await new AssertIsCancellationRequestedAsyncSequence<Unit>().InspectAwait(_ => ValueTask.CompletedTask).ToListAsync(canceledToken);
}
}

#endif
4 changes: 2 additions & 2 deletions ...yncEnumerableExtensions/InterleaveTest.cs → ...yncEnumerableExtensions/InterleaveTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class InterleaveTest
{
Expand Down
4 changes: 2 additions & 2 deletions ...ncEnumerableExtensions/IntersperseTest.cs → ...ncEnumerableExtensions/IntersperseTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class IntersperseTest
{
Expand Down
2 changes: 1 addition & 1 deletion ...cEnumerableExtensions/JoinToStringTest.cs → ...cEnumerableExtensions/JoinToStringTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
// ReSharper disable PossibleMultipleEnumeration

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class JoinToStringTest
{
Expand Down
4 changes: 2 additions & 2 deletions ...yncEnumerableExtensions/LastOrNoneTest.cs → ...yncEnumerableExtensions/LastOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
using static Funcky.Async.Test.Extensions.AsyncEnumerableExtensions.TestData;
using static Funcky.Test.Extensions.AsyncEnumerableExtensions.TestData;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class LastOrNoneTest
{
Expand Down
4 changes: 2 additions & 2 deletions ...ncEnumerableExtensions/MaterializeTest.cs → ...ncEnumerableExtensions/MaterializeTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.TestUtils;
using Xunit.Sdk;

namespace Funcky.Test.Extensions.EnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class MaterializeTest
{
Expand Down
6 changes: 5 additions & 1 deletion ...syncEnumerableExtensions/MaxOrNoneTest.cs → ...syncEnumerableExtensions/MaxOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,12 @@
#if !NET48

// ReSharper disable PossibleMultipleEnumeration
using FsCheck;
using FsCheck.Fluent;
using Funcky.Test.Internal;
using Funcky.Test.Internal.Data;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class MaxOrNoneTest
{
Expand Down Expand Up @@ -211,3 +213,5 @@ private static async Task<bool> CompareMaxAndHandleEmptyPersonSequence(IAsyncEnu
? (await sequence.MaxOrNoneAsync()).Match(none: false, some: p => p.CompareTo(sequence.MaxAsync().Result) == 0)
: (await sequence.MaxOrNoneAsync()).Match(none: true, some: _ => false);
}

#endif
8 changes: 6 additions & 2 deletions .../AsyncEnumerableExtensions/MemoizeTest.cs → .../AsyncEnumerableExtensions/MemoizeTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
using Funcky.Async.Test.TestUtilities;
#if !NET48

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
using Funcky.Test.TestUtils;

namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class MemoizeTest
{
Expand Down Expand Up @@ -107,3 +109,5 @@ public async Task UsagesOfSecondBorrowThrowAfterFirstBorrowIsDisposed()
await Assert.ThrowsAsync<ObjectDisposedException>(async () => await secondBorrow.ForEachAsync(NoOperation<int>));
}
}

#endif
4 changes: 2 additions & 2 deletions ...ns/AsyncEnumerableExtensions/MergeTest.cs → ...ns/AsyncEnumerableExtensions/MergeTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@

using System.Collections.Immutable;
using FsCheck.Xunit;
using Funcky.Async.Test.TestUtilities;
using Funcky.Test.Internal;
using Funcky.Test.TestUtils;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class MergeTest
{
Expand Down
6 changes: 5 additions & 1 deletion ...syncEnumerableExtensions/MinOrNoneTest.cs → ...syncEnumerableExtensions/MinOrNoneTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,10 +1,12 @@
#if !NET48

// ReSharper disable PossibleMultipleEnumeration
using FsCheck;
using FsCheck.Fluent;
using Funcky.Test.Internal;
using Funcky.Test.Internal.Data;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class MinOrNoneTest
{
Expand Down Expand Up @@ -211,3 +213,5 @@ private static async Task<bool> CompareMinAndHandleEmptyPersonSequence(IAsyncEnu
? (await sequence.MinOrNoneAsync()).Match(none: false, some: p => p.CompareTo(sequence.MinAsync().Result) == 0)
: (await sequence.MinOrNoneAsync()).Match(none: true, some: _ => false);
}

#endif
6 changes: 3 additions & 3 deletions ...AsyncEnumerableExtensions/PairwiseTest.cs → ...AsyncEnumerableExtensions/PairwiseTest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
using Funcky.Async.Test.TestUtilities;
using static Funcky.Async.Test.Extensions.AsyncEnumerableExtensions.TestData;
using Funcky.Test.TestUtils;
using static Funcky.Test.Extensions.AsyncEnumerableExtensions.TestData;

namespace Funcky.Async.Test.Extensions.AsyncEnumerableExtensions;
namespace Funcky.Test.Extensions.AsyncEnumerableExtensions;

public sealed class PairwiseTest
{
Expand Down
Loading