State management with Channels

Question

I am currently working with a Channels construct (like go routine) to manage multi-threaded state synchronization.

I'm curious as to the best practice on how to handle different operations for state management using that channel. One operation could be retrieval, and another could be to re-load that state from disk.

I'm feeling quite a bit of friction and complexity in supporting multiple operations using a single channel with parameter support for those operations. Specifically supporting different return types and the casting inside each operation decision path within that channel.

Can someone recommend some alternative ways or is this concept sufficient?

Here's an example:

private static readonly Dictionary<string, OmaObject> State = new Dictionary<string, OmaObject>(); 
private static readonly ISpookyHashV2 SpookyHashV2 = SpookyHashV2Factory.Instance.Create();

 public static ChannelReader<T> CreateScheduleMessenger<T>(ChannelReader<T> channelReader,
           Command command)
        {
            var output = Channel.CreateUnbounded<T>();
            
            Task.Run(async () =>
            {
                
                if (command is Command.Get)
                {
                        var raw = await channelReader.ReadAsync();
                        OmaObject omaObject = (OmaObject)Convert.ChangeType(raw, typeof(OmaObject));

                        var hash = SpookyHashV2.ComputeHash($"{omaObject.Customer}{omaObject.Device}{omaObject.TestName}").AsBase64String();
                        if (!State.ContainsKey(hash))
                            State.Add(hash, omaObject);

                        Console.WriteLine($"Schedule state count: {State.Count}");
                        await output.Writer.WriteAsync((T)omaObject);

                    
                } else if (command is Command.Delete)
                {
                        var omaObject = await channelReader.ReadAsync();
                        State.Clear();
                        Console.WriteLine($"State has been cleaned: {State.Count}");

                        await output.Writer.WriteAsync(true);
                        
                }
            
            });
            
            output.Writer.Complete();

            return output;
 }