在ServiceStack中为用户订阅SSE频道

public class MyService : Service
{
    public object Any(SubscribeToSseChannel request)
    {
        // 处理SSE订阅逻辑
        // ...
    }
}

[Route("/sse/subscribe")]
public class SubscribeToSseChannel : IReturnVoid
{
    public string Channel { get; set; }
}

public class AppHost : AppHostBase
{
    public AppHost() : base("MyApp", typeof(MyService).Assembly) { }

    public override void Configure(Container container)
    {
        Plugins.Add(new ServerEventsFeature());
    }
}

public class Program
{
    public static void Main(string[] args)
    {
        var appHost = new AppHost();
        appHost.Init();
        appHost.Start("http://localhost:5000/");
        Console.ReadLine();
    }
}

var client = new JsonServiceClient("http://localhost:5000/");
var request = new SubscribeToSseChannel { Channel = "myChannel" };
client.Post(request);