System.Web.HttpエンドポイントをIObservableにすることはできますか？

Question

System.Web.HttpエンドポイントをIObservableにすることはできますか？それはRouteやAcceptVerbsのような属性を使っている間に行うことができますか？

は基本的に、私は私が加入して反応性の拡張機能を経由して、それを処理していますので、IObservableストリームに次のコード例を作りたい：

[Route("{id}")] 
    [AcceptVerbs("GET")] 
    public async Task<IHttpActionResult> example(int id) 
    { 
     return Ok(await Service.GetExampleAsync(id)); 
    } 

編集：私のような、よりエレガントな解決策を探しています https://blogs.msdn.microsoft.com/jeffva/2010/09/15/rx-on-the-server-part-5-of-n-observable-asp-net（IHttpHandlerから観察可能）、7年後にはもっと成熟したほうがいいですか？

Answer 1

直接的な方法はありません。しかし、自分でObservableを公開することもできます。主な問題は、example関数の値を返す必要があることです。

解決策の1つは、TaskCompletionSourceを渡すObservableを作成することです。これにより、イベントハンドラから結果を設定することができます。上記の例で

public class Request 
{ 
    public int Parameter { get; } 

    public Request(int parameter) 
    { 
     Parameter = parameter; 
    } 

    public TaskCompletionSource<IHttpActionResult> Result { get; } = new TaskCompletionSource<IHttpActionResult>(); 
} 

public class Handler 
{ 
    public Subject<Request> ExampleObservable { get; } = new Subject<Request>(); 

    [Route("{id}")] 
    [AcceptVerbs("GET")] 
    public async Task<IHttpActionResult> example(int id) 
    { 
     var req = new Request(id); 
     ExampleObservable.OnNext(req); 
     return await req.Result.Task; 
    } 
} 

、我々は、ExampleObservableにRequestを押します。これを購読してRequest.Result.SetResult(...)を使用してリクエストを返すことができます。

ExampleObservable.Subscribe(req => req.Result.SetResult(Ok(Service.GetExample(id)));