CounterGrain.cs

public class CounterGrain : ReduxGrain<CounterState>, ICounterGrain
{
    IDisposable storeSubscription;
    IAsyncStream<IAction> actionsToClientStream;

    public CounterGrain(ReduxTableStorage<CounterState> storage) : base(CounterState.Reducer, storage)
    {
    }
    
    public override async Task OnActivateAsync()
    {
        // Do this first, it initializes the Store!
        await base.OnActivateAsync();
        
        // Get stream to client with corresponding session id
        var streamProvider = this.GetStreamProvider("Default");
        this.actionsToClientStream = streamProvider.GetStream<IAction>(this.GetPrimaryKey(), "ActionsToClient");

        // Subscribe to state updates as they happen on the server, and publish them using the SyncCounterState action
        this.storeSubscription = this.Store.Subscribe(
            async (CounterState state) => {
                if (state != null)
                    await this.actionsToClientStream.OnNextAsync(new SyncCounterStateAction { CounterState = state });
            });
    }
    
    public override async Task OnDeactivateAsync()
    {
        // clean up when grain goes away
        this.storeSubscription.Dispose();
        await base.OnDeactivateAsync();
    }
    

    public async Task IncrementCounter()
    {
        await this.Dispatch(new IncrementCounterAction());
        await this.WriteStateAsync();
    }
    
    // [ ... other methods ]
}