Mostlylucid.Ephemeral.Atoms.Batching 2.6.3

.NET 8.0 This package targets .NET 8.0. The package is compatible with this framework or higher. 
dotnet add package Mostlylucid.Ephemeral.Atoms.Batching --version 2.6.3
                    


                    

                
NuGet\Install-Package Mostlylucid.Ephemeral.Atoms.Batching -Version 2.6.3
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="Mostlylucid.Ephemeral.Atoms.Batching" Version="2.6.3" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
<PackageVersion Include="Mostlylucid.Ephemeral.Atoms.Batching" Version="2.6.3" />
                    


                            Directory.Packages.props
                        

                    

                
<PackageReference Include="Mostlylucid.Ephemeral.Atoms.Batching" />
                    


                            Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package. 
paket add Mostlylucid.Ephemeral.Atoms.Batching --version 2.6.3
                    


                    

                
#r "nuget: Mostlylucid.Ephemeral.Atoms.Batching, 2.6.3"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
#:package Mostlylucid.Ephemeral.Atoms.Batching@2.6.3
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package. 
#addin nuget:?package=Mostlylucid.Ephemeral.Atoms.Batching&version=2.6.3
                    


                            Install as a Cake Addin
                        

                    

                
#tool nuget:?package=Mostlylucid.Ephemeral.Atoms.Batching&version=2.6.3
                    


                            Install as a Cake Tool

Mostlylucid.Ephemeral.Atoms.Batching

NuGet

Collect items into batches by size or time interval before processing.

dotnet add package mostlylucid.ephemeral.atoms.batching

Quick Start

using Mostlylucid.Ephemeral.Atoms.Batching;

await using var atom = new BatchingAtom<LogEntry>(
    onBatch: async (batch, ct) => await FlushToDatabase(batch, ct),
    maxBatchSize: 100,
    flushInterval: TimeSpan.FromSeconds(5));

// Items batched automatically
atom.Enqueue(new LogEntry("User logged in"));
atom.Enqueue(new LogEntry("Request received"));
// Flushes when full OR after 5 seconds

All Options

new BatchingAtom<T>(
    // Required: async batch processor
    onBatch: async (batch, ct) => await ProcessBatch(batch, ct),

    // Flush when batch reaches this size
    // Default: 32
    maxBatchSize: 100,

    // Flush after this interval even if not full
    // Default: 1 second
    flushInterval: TimeSpan.FromSeconds(5)
)

API Reference

// Add item to batch (non-blocking, synchronous)
atom.Enqueue(item);

// Dispose - flushes remaining items
await atom.DisposeAsync();

Flush Behavior

Flushes when either condition is met:

  • Size: Batch reaches maxBatchSize
  • Time: flushInterval elapses
[1] [2] [3] ... [100] -> FLUSH (size)
[1] [2] [3] (5s pass) -> FLUSH (time)

Example: Log Aggregation

await using var atom = new BatchingAtom<LogEntry>(
    onBatch: async (batch, ct) =>
    {
        Console.WriteLine($"Flushing {batch.Count} entries");
        await database.BulkInsertAsync(batch, ct);
    },
    maxBatchSize: 500,
    flushInterval: TimeSpan.FromSeconds(10));

foreach (var entry in incomingLogs)
    atom.Enqueue(entry);  // Non-blocking

Example: Metrics

await using var atom = new BatchingAtom<Metric>(
    onBatch: async (batch, ct) =>
    {
        var aggregated = batch
            .GroupBy(m => m.Name)
            .Select(g => new { Name = g.Key, Avg = g.Average(m => m.Value) });
        await metricsService.ReportAsync(aggregated, ct);
    },
    maxBatchSize: 1000,
    flushInterval: TimeSpan.FromMinutes(1));

atom.Enqueue(new Metric("response_time", 42.5));
Package Description
mostlylucid.ephemeral Core library
mostlylucid.ephemeral.complete All in one DLL

License

Unlicense (public domain)

Product Compatible and additional computed target framework versions.
.NET net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed.  net9.0 is compatible.  net9.0-android was computed.  net9.0-browser was computed.  net9.0-ios was computed.  net9.0-maccatalyst was computed.  net9.0-macos was computed.  net9.0-tvos was computed.  net9.0-windows was computed.  net10.0 is compatible.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages (2)

Showing the top 2 NuGet packages that depend on Mostlylucid.Ephemeral.Atoms.Batching:

Package Downloads
mostlylucid.botdetection

DEPRECATION NOTICE: This package will be renamed to 'stylobot' on June 1 2025. Version 7.0 will publish under the new name with a Stylobot.* namespace. See https://github.com/scottgal/stylobot/blob/main/docs/migration-v7.md Bot detection middleware for ASP.NET Core applications with behavioral analysis, header inspection, IP-based detection, and optional LLM-based classification.
mostlylucid.ephemeral.complete

Meta-package that references all Mostlylucid.Ephemeral packages - bounded async execution with signals, atoms, and patterns. Install this single package to get everything.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last Updated
2.6.3 35 5/22/2026
2.6.2 37 5/22/2026
2.6.0 36 5/22/2026
2.5.1 39 5/22/2026
2.5.0 2,755 5/3/2026
2.4.0 99 4/17/2026
2.3.2 128 1/9/2026
2.3.1 119 1/9/2026
2.3.1-alpha0 114 1/9/2026
2.3.0 1,149 1/8/2026
2.3.0-alpha1 120 1/8/2026
2.2.0-alpha0 115 1/8/2026
2.1.0 116 1/8/2026
2.1.0-preview 122 1/8/2026
2.0.1 122 1/8/2026
2.0.0 158 1/8/2026
2.0.0-alpha1 112 1/8/2026
2.0.0-alpha0 112 1/8/2026
1.7.1 441 12/11/2025
1.6.8 460 12/9/2025
Loading failed