CSV Parsing

FastCsvReader

High-performance, allocation-free CSV parser.

string csv = "Id;Name;Value\n1;Foo;100\n2;Bar;200";
var reader = new FastCsvReader(csv, ";");

while (reader.NextLine())
{
    int id = reader.ReadInt();
    string name = reader.ReadString();
    decimal value = reader.ReadDecimal();

    Console.WriteLine($"{id}: {name} = {value}");
}

Reading Different Types

var reader = new FastCsvReader(data, ",");

while (reader.NextLine())
{
    // Primitives
    int intVal = reader.ReadInt();
    long longVal = reader.ReadLong();
    double doubleVal = reader.ReadDouble();
    decimal decimalVal = reader.ReadDecimal();
    bool boolVal = reader.ReadBool();

    // Nullable types
    int? nullableInt = reader.ReadNullableInt();

    // Date/Time
    DateTime date = reader.ReadDateTime("yyyy-MM-dd");
    TimeSpan time = reader.ReadTimeSpan();

    // Enum
    MyEnum enumVal = reader.ReadEnum<MyEnum>();

    // Skip column
    reader.Skip();
}

Time Utilities

High-Precision Time

using Ecng.Common;

// High-precision current time (uses Stopwatch internally)
DateTime now = TimeHelper.Now;
DateTimeOffset nowWithOffset = TimeHelper.NowWithOffset;

// Adjust time offset (for testing or sync)
TimeHelper.NowOffset = TimeSpan.FromSeconds(5);

// Sync with NTP server
TimeHelper.SyncMarketTime(timeout: 5000);

TimeSpan Extensions

TimeSpan span = TimeSpan.FromDays(365);

double weeks = span.TotalWeeks();
double months = span.TotalMonths();
double years = span.TotalYears();

// Constants
long ticksPerWeek = TimeHelper.TicksPerWeek;
long ticksPerMonth = TimeHelper.TicksPerMonth;
long ticksPerYear = TimeHelper.TicksPerYear;

// Predefined spans
TimeSpan oneMinute = TimeHelper.Minute1;
TimeSpan fiveMinutes = TimeHelper.Minute5;
TimeSpan oneHour = TimeHelper.Hour1;

DateTime Extensions

DateTime dt = DateTime.Now;

// Truncation
DateTime dateOnly = dt.Truncate(TimeSpan.FromDays(1));
DateTime hourOnly = dt.Truncate(TimeSpan.FromHours(1));

// Apply timezone
DateTimeOffset local = dt.ApplyLocal();
DateTimeOffset utc = dt.ApplyUtc();
DateTimeOffset custom = dt.ApplyTimeZone(TimeZoneInfo.FindSystemTimeZoneById("Eastern Standard Time"));

// Async delay
await TimeSpan.FromSeconds(1).Delay(cancellationToken);

I/O Utilities

File Operations

using Ecng.Common;

// Safe file operations
string content = IOHelper.ReadFile("path/to/file.txt");
IOHelper.WriteFile("path/to/file.txt", content);

// Atomic file write (writes to temp, then renames)
IOHelper.AtomicWriteFile("path/to/file.txt", content);

// Get relative path
string relative = IOHelper.GetRelativePath(basePath, fullPath);

Stream Extensions

// Read all bytes
byte[] data = stream.ReadToEnd();

// Copy with progress
await source.CopyToAsync(destination, progress: bytesWritten =>
{
    Console.WriteLine($"Written: {bytesWritten}");
});

Math Utilities

using Ecng.Common;

// Rounding
double rounded = 3.7.Round();      // 4
double ceiling = 3.1.Ceiling();    // 4
double floor = 3.9.Floor();        // 3

// Clamping
int clamped = 150.Max(100);        // 100
int clamped2 = 50.Min(100);        // 100

// Abs
int absolute = (-5).Abs();         // 5

// Percentage
decimal pct = 250m.Percent(1000m); // 25

Random Generation

using Ecng.Common;

// Random values
int randomInt = RandomGen.GetInt(1, 100);
double randomDouble = RandomGen.GetDouble();
bool randomBool = RandomGen.GetBool();

// Random bytes
byte[] randomBytes = RandomGen.GetBytes(32);

// Random string
string randomStr = RandomGen.GetString(16);

Disposable Helpers

Base Disposable Class

public class MyResource : Disposable
{
    private IntPtr _handle;

    protected override void DisposeManaged()
    {
        // Clean up managed resources
        base.DisposeManaged();
    }

    protected override void DisposeNative()
    {
        // Clean up native resources
        CloseHandle(_handle);
        base.DisposeNative();
    }
}

Disposable Scope

// Dispose multiple objects at once
using var scope = new DisposeScope(resource1, resource2, resource3);

// Or with extension
resource1.DisposeWith(scope);

File System Abstraction

IFileSystem Interface

// Local file system
IFileSystem fs = new LocalFileSystem();

// In-memory file system (for testing)
IFileSystem memFs = new MemoryFileSystem();

// Operations
bool exists = fs.FileExists("path/to/file");
byte[] data = fs.ReadAllBytes("path/to/file");
fs.WriteAllBytes("path/to/file", data);
fs.CreateDirectory("path/to/dir");
IEnumerable<string> files = fs.GetFiles("path", "*.txt");

Currency Support

// Currency types
CurrencyTypes usd = CurrencyTypes.USD;
CurrencyTypes eur = CurrencyTypes.EUR;

// Currency operations
Currency amount = new Currency(100, CurrencyTypes.USD);
string display = amount.ToString(); // "$100.00"

Cloning

// Deep clone
var clone = original.Clone();

// Typed clone
public class MyClass : Cloneable<MyClass>
{
    public override MyClass Clone()
    {
        return new MyClass { /* copy properties */ };
    }
}

Watch (Benchmarking)

using var watch = new Watch("Operation name");

// Do work...

// Automatically logs elapsed time on dispose
// Or get elapsed manually
TimeSpan elapsed = watch.Elapsed;

NuGet

Install-Package Ecng.Common