Akka.Analyzer demos

badpipeto.cs

using Akka.Actor;
using System.Threading.Tasks;

public sealed class MyActor : ReceiveActor{

    public MyActor(){
        Receive<string>(str => {
            async Task<int> LocalFunction(){
                await Task.Delay(10);
                return str.Length;
            }

            // incorrect use of closure
            LocalFunction().PipeTo(Sender); 
        });
    }
}

shardingcode.cs

 using Akka.Cluster.Sharding;
                     
                     public class MsgExtractorCreator{
                         IMessageExtractor Create(){
                            IMessageExtractor messageExtractor = HashCodeMessageExtractor.Create(100, msg =>
                            {
                                if (msg is ShardingEnvelope shard) {
                                   return shard.EntityId;
                                }
                                else if (msg is string s) {
                                    return s;
                                }
                                else{
                                    return null;
                                }
                             });
                         
                             return messageExtractor;
                         }
                     }