如何将Akka.Net Streams与AspNet核心或giraffe集成

var system = ActorSystem.Create("MyActorSystem");

public class MyActor : ReceiveActor
{
    public MyActor()
    {
        Receive<string>(message =>
        {
            // 处理流数据
        });
    }
}

var source = Source.ActorRef<string>(bufferSize: 100, OverflowStrategy.DropBuffer);

var flow = Flow.FromSinkAndSource(Sink.ActorRef<string>(system.ActorOf<MyActor>(), "completed"), source);

app.Use(async (context, next) =>
{
    using (var materializer = ActorMaterializer.Create(system))
    {
        var materializedFlow = flow.RunWith(materializer);
        var requestContent = await new StreamReader(context.Request.Body).ReadToEndAsync();
        materializedFlow.Item1.Tell(requestContent);

        // 等待流数据处理完成
        await materializedFlow.Item2;

        await next();
    }
});

let akkaStreamMiddleware (next : HttpFunc) (ctx : HttpContext) : Task =
    async {
        use materializer = ActorMaterializer.Create(system)
        let materializedFlow = flow.Run(materializer)
        let! requestContent = ctx.Request.StreamReaderAsync() |> Async.AwaitTask
        materializedFlow.Item1.Tell(requestContent)

        // 等待流数据处理完成
        do! materializedFlow.Item2

        do! next ctx
    }

app.UseMiddleware(akkaStreamMiddleware)