Observable 또는 async/await를 사용하여 비동기 콜백을 래핑하는 방법은 무엇입니까?

Question

콜백과 함께 작동하는 네트워크 API를 사용하고 있습니다. 그러니까 기본적으로, 나는 방법의 무리 I는 다음과 같이이 제 3 자 라이브러리에서 사용할 필요가 통화를 할 :

void SendNetworkRequest(string requestType, Action<Response> callback) 

내가 코드를 약간 이상한 점점을 찾을 네트워크에 의존 내 모든 방법 때문에 이 제 3 자 API의 리소스도 콜백 자체를 구현해야합니다. 예를 들어, 내 주요 장면에서 나는 선수 정보를 얻을 할 수 있으며, 내 코드는 다음과 같이 보일 것입니다 :

void InitMainScene() 
{ 
     _networkHelper.SendNetworkRequest("GetPlayersInfo",OnPlayerInfoResponse); 
} 

void OnPlayerInfoResponse(Response response) 
{ 
    _playerInfo = response.Info; 
} 

나는 최근 RX에 입수했습니다 내 코드에서 abundently을 사용하고 있습니다. 나는 async/await에 관해 읽은 것을 읽었다. RX를 사용하여 꽤 많은 실험을 해본 결과 Observable.FromAsync()를 사용해 보았지만 작동하지 못했습니다 ..

여기서 무엇이 누락 되었습니까? RX 또는 async/await를 사용하여 콜백이 필요없는 코드를 더 깨끗하게 작성할 수 있습니까? 다음은 내가 찾는 psuedocode입니다 :

 void InitMainScene() 
     { 
      _playerInfo = Overservable.DoMagicThing<Response>(() => { 
_networkHelper.SendNetworkRequest("GetPlayersInfo",(r) =>{return r;}); }); 
     } 

Answer 1

RX에 대해서는 확실하지 않습니다. 그러나이 같은 awaitable 작업에 콜백 기반 SendNetworkRequest을 변환 할 수 있습니다

void SendNetworkRequest(string requestType, Action<Response> callback) 
     { 
      // This code by third party, this is here just for testing 
      if (callback != null) 
      { 
       var result = new Response(); 
       callback(result); 
      } 
     } 

     Task<Response> SendNetworkRequestAsync(string requestType) 
     { 
      return Task.Run(() => 
      { 
       var t = new TaskCompletionSource<Response>(); 

       SendNetworkRequest(requestType, s => t.TrySetResult(s)); 

       return t.Task; 
      }); 
     } 

이제 당신은/비동기로 SendNetworkRequestAsync을 소비 할 수 있습니다 여기에

Answer 2

가 수신와 함께 할 방법은 더 자연스럽게 기다리고 있습니다. 난 그냥 내가 컴파일 및 테스트,하지만 사소한 다시 :

public IObservable<string> SendNetworkRequestObservable(string requestType) 
{ 
    return Observable.Create<string>(observer => 
    { 
     SendNetworkRequest(requestType, s => observer.OnNext(s)); 
     observer.OnCompleted(); 
     return Disposable.Empty; 
    }); 
} 

// Define other methods and classes here 
public void SendNetworkRequest(string requestType, Action<string> callback) 
{ 
    callback(requestType); // implementation for testing purposes 
} 

Answer 3

다음은 수신과 함께이 일에 내 걸릴이야를 교환 할 수 string에 대한 Response을 교환. 이 내부적으로 SendNetworkRequest 메서드에 전달 된 Action<Response> callback에 하나의 전화를 기다리고 기반으로 관찰을 만들 Observable.FromEvent(...).Take(1)를 사용하는 관측을 생성

public IObservable<Response> SendNetworkRequestObservable(string requestType) 
{ 
    return 
     Observable 
      .Create<Response>(observer => 
      { 
       Action<Response> callback = null; 
       var callbackQuery = 
        Observable 
         .FromEvent<Response>(h => callback += h, h => callback -= h) 
         .Take(1); 
       var subscription = callbackQuery.Subscribe(observer); 
       this.SendNetworkRequest(requestType, callback); 
       return subscription; 
      }); 
} 

다음 NetworkHelper 클래스 내부

이 방법을 추가 할 수 있습니다.

유일한 문제는 현재 스레드에서 호출이 완료 될 때까지 발생한다는 것입니다. 당신이 백그라운드 스레드에서 실행되지만 현재 스레드에 결과를 반환이 코드를 원하는 경우에, 당신은이 작업을 수행 할 수 있습니다

var _playerInfo = 
    _networkHelper 
     .SendNetworkRequestObservable("GetPlayersInfo") 
     .Wait(); 

:

public IObservable<Response> SendNetworkRequestObservable(string requestType) 
{ 
    return 
     Observable 
      .Start(() => 
       Observable 
        .Create<Response>(observer => 
        { 
         Action<Response> callback = null; 
         var callbackQuery = 
          Observable 
           .FromEvent<Response>(h => callback += h, h => callback -= h) 
           .Take(1); 
         var subscription = callbackQuery.Subscribe(observer); 
         this.SendNetworkRequest(requestType, callback); 
         return subscription; 
        })) 
      .Merge(); 
} 

어느 쪽이든 당신은 다음과 같이 호출 것

그냥 쪽지 : DoMagicThing은 동기 호출입니다. Rx의 경우 .Wait() 전화가 있지만 가능하면 정상적인 .Subscribe을 사용하는 것이 좋습니다.

---

코멘트 당, 당신이 async이 할 수 있습니다 :

async void InitMainScene() 
{ 
    _playerInfo = await _networkHelper.SendNetworkRequestObservable("GetPlayersInfo"); 
}