Gapotchenko.FX.Linq.Async 2026.7.2

Overview

The module provides asynchronous LINQ extensions and utilities for working with IAsyncEnumerable<T> sequences, including bridging between synchronous and asynchronous enumeration models.

AsyncEnumerableBridge

AsyncEnumerableBridge static class provides methods to bridge synchronous and asynchronous enumeration models together, allowing seamless conversion between IEnumerable<T> and IAsyncEnumerable<T>.

Converting Asynchronous Enumerable to Synchronous

You can synchronously enumerate values from an asynchronous source:

using Gapotchenko.FX.Linq;

IAsyncEnumerable<string> asyncSource = GetAsyncStrings();

// Synchronously enumerate from async source
foreach (string item in AsyncEnumerableBridge.Enumerate(asyncSource))
    Console.WriteLine(item);

Converting Synchronous Enumerable to Asynchoronous

You can asynchronously enumerate values from a synchronous source:

using Gapotchenko.FX.Linq;

IEnumerable<string> syncSource = GetStrings();

// Asynchronously enumerate from sync source
await foreach (string item in AsyncEnumerableBridge.EnumerateAsync(syncSource))
    Console.WriteLine(item);

// With cancellation support
var cancellationToken = ...;
await foreach (string item in AsyncEnumerableBridge.EnumerateAsync(syncSource, cancellationToken))
    Console.WriteLine(item);

When cancellation is requested, the thread executing the synchronous enumeration is terminated.

ScalarOrDefaultAsync

The ScalarOrDefaultAsync() extension method provides safe scalar extraction from asynchronous sequences. Unlike SingleOrDefaultAsync() from conventional .NET, it does not throw an exception when a sequence contains multiple elements.

The method follows the same safe semantics as ScalarOrDefault() from Gapotchenko.FX.Linq:

• Returns the element if the sequence contains exactly one element
• Returns the default value if the sequence is empty
• Returns the default value if the sequence contains multiple elements

This allows you to safely determine whether a given asynchronous query converges to a scalar result without exception handling.

Related Modules

• Gapotchenko.FX.Linq - Provides synchronous LINQ extensions and primitives
• Gapotchenko.FX.Threading - Provides threading primitives, including bridging between synchronous and asynchronous execution models

Other Modules

Let's continue with a look at some other modules provided by Gapotchenko.FX:

• Gapotchenko.FX
• Gapotchenko.FX.AppModel.Information
• Gapotchenko.FX.Collections
• Gapotchenko.FX.Console
• Gapotchenko.FX.Data
• Gapotchenko.FX.Diagnostics
• Gapotchenko.FX.IO
• Gapotchenko.FX.Linq
  • ➴ Gapotchenko.FX.Linq.Async
• Gapotchenko.FX.Math
• Gapotchenko.FX.Memory
• Gapotchenko.FX.Security.Cryptography
• Gapotchenko.FX.Text
• Gapotchenko.FX.Threading
• Gapotchenko.FX.Tuples
• Gapotchenko.FX.Versioning

Or look at the full list of modules.