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 함수에서 값을 반환해야한다는 것입니다.

하나의 해결책은 TaskCompletionSource을 전달하는 Observable을 만드는 것일 수 있습니다. 이렇게하면 Event Handler에서 결과를 설정할 수 있습니다. 위의 예에서

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)));