using NATS.Client.Core;

TaskScheduler.UnobservedTaskException += (sender, eventArgs) =>
{
    Console.WriteLine($"Unobserved task exception: {eventArgs.Exception}");
    eventArgs.SetObserved();
};

var connection
    = new NatsConnection(
        NatsOpts.Default with { Url = "nats:/user@pass:sorry" });

await using (connection.ConfigureAwait(false))
{
    try
    {
        await connection.ConnectAsync().ConfigureAwait(false);
        Console.WriteLine("Connected to NATS server.");
    }
    catch (Exception ex)
    {
        Console.WriteLine($"Failed to connect to NATS server: {ex.Message}");
    }

    await Task.Delay(500).ConfigureAwait(false);

    GC.Collect();
    GC.WaitForPendingFinalizers();

    Console.WriteLine("Exiting application.");
}