egil

public class ExampleTest(SiloFixture fixture) : IClassFixture<SiloFixture>
{
    [Fact]
    public async Task Sending_data_to_stream()
    {
        var message = "foo bar baz";
        var stream = fixture.GetStream<string>("grainId1");

        await stream.OnNextAsync(message);

egil

using Orleans.Storage;
using R3;

namespace Egil.Orleans.Storage.Testing;

public sealed class StorageObserver(string storageName, IGrainStorage observableTarget) : IGrainStorage
{
    private readonly Subject<StorageOperation> operationsFeed = new();

    public Observable<StorageOperation> StorageOperationFeed => operationsFeed.AsObservable();

egil

using System.Collections.Concurrent;
using System.Globalization;
using Orleans.Storage;
// https://www.nuget.org/packages/R3
using R3; 
using Xunit.Sdk;

namespace Egil.Orleans.Storage.Testing;

public sealed class ObservableMemoryStorage : IGrainStorage

egil

var builder = DistributedApplication.CreateBuilder(args);

var sqlPassword = builder.AddParameter("sql-password", secret: true);
var sqlserver = builder
    .AddSqlServer("sqlserver", password: sqlPassword)
    .WithDataVolume()
    .WithLifetime(ContainerLifetime.Persistent);

var importSourceConnectionString = "Server=[REPLACE].database.windows.net;Authentication=Active Directory Interactive;Database=[REPLACE];Encrypt=True;"
var db = sqlserver

egil

public sealed class RecordList<T> : List<T>, IEquatable<RecordList<T>>
    where T : IEquatable<T>
{
    private static readonly int EmptyRecordListHashCode = typeof(RecordList<T>).FullName!.GetHashCode(StringComparison.Ordinal);

    public RecordList()
    {
    }

    public RecordList(IEnumerable<T> collection)

egil

using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Caching.Memory;

namespace Solution.Data;

public sealed class CustomerRepository : IDisposable
{
    private readonly IDbContextFactory<DbContext> dbFactory;
    private readonly DatabaseMemoryCache databaseCache;

egil

param resourceName string
param subnetId string
param appServicePlanId string
param appsettingsProperties object
param location string = resourceGroup().location
param tags object = resourceGroup().tags
param eventHubNames array

resource appService 'Microsoft.Web/sites@2022-09-01' = {
  name: resourceName

egil

<!-- 
Automatically copy the content of a CHANGELOG.md file into a NuGET package's change log section via the `<PackageReleaseNotes>` element in .csproj by doing the following:

Put the following into your .csproj, e.g. `Lib.csproj`, and the content of your CHANGELOG.md will be embedded when the project is packaged.

This assumes that the project structure is as follows:

\CHANGELOG.md
\src\Lib\Lib.csproj
-->

egil

function Invoke-With-Retry {
  [CmdletBinding()]
  Param(
    [Parameter(Position = 0, Mandatory = $true)]
    [scriptblock]$ScriptBlock,

    [Parameter(Position = 1, Mandatory = $false)]
    [int]$Retries = 5,

    [Parameter(Position = 2, Mandatory = $false)]

egil

using System;
using System.Linq.Expressions;
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.Serialization;

namespace Microsoft.Extensions.Options;

public static class OptionsExtensions
{