Mostlylucid.Ephemeral.Atoms.Batching 2.10.0

.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.10.0
                    


                    

                
NuGet\Install-Package Mostlylucid.Ephemeral.Atoms.Batching -Version 2.10.0
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.10.0" />
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.10.0" />
                    


                            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.10.0
                    


                    

                
#r "nuget: Mostlylucid.Ephemeral.Atoms.Batching, 2.10.0"
#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.10.0
#: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.10.0
                    


                            Install as a Cake Addin
                        

                    

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


                            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

Enterprise bot detection and anonymous entity resolution for ASP.NET Core — the detection engine behind StyloBot (https://stylo.bot). Probabilistic and behavioural, not just User-Agent matching: UA/header/IP analysis, JA3/JA4/HTTP2/QUIC/TCP-IP fingerprinting, Leiden cluster discovery, 129-dim Markov session vectors, metastable fingerprint identity, and optional LLM classification. Zero-PII (HMAC-SHA256), SQLite-backed, single-call UseStyloBot() setup.
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.10.0 3,179 7/23/2026
2.9.1 2,124 7/9/2026
2.9.0 195 7/8/2026
2.8.1 103 7/6/2026
2.7.0 103 7/4/2026
2.6.4 1,319 6/21/2026
2.6.3 3,367 5/22/2026
2.6.2 109 5/22/2026
2.6.0 108 5/22/2026
2.5.1 111 5/22/2026
2.5.0 3,753 5/3/2026
2.4.0 117 4/17/2026
2.3.2 137 1/9/2026
2.3.1 136 1/9/2026
2.3.1-alpha0 124 1/9/2026
2.3.0 1,315 1/8/2026
2.3.0-alpha1 131 1/8/2026
2.2.0-alpha0 125 1/8/2026
2.1.0 135 1/8/2026
2.1.0-preview 132 1/8/2026
Loading failed