IObservable <T> .ToTask <T> phương thức trả về nhiệm vụ đang chờ kích hoạt

Question

Tại sao task chờ đợi mãi mãi ?:

var task = Observable 
    .FromEventPattern<MessageResponseEventArgs>(communicator, "PushMessageRecieved") 
    .Where(i => i.EventArgs.GetRequestFromReceivedMessage().Name == requestName) 
    .Select(i => i.EventArgs) 
    .RunAsync(System.Threading.CancellationToken.None) 
    .ToTask(); 

task.Wait(); 

Tôi biết "PushMessageRecieved" là bắn; Tôi có thể thiết lập một điểm break trên Select lambda và nhấn nó. Nhưng task.Wait() không bao giờ di chuyển. Cập nhật

tốt hơn:FirstAsync() là những gì tôi đang tìm kiếm:

public static Task<MessageResponseEventArgs> HandlePushMessageRecievedAsync(this ICommunicator communicator, RequestName requestName) 
    { 
     if (communicator == null) return Task.FromResult<MessageResponseEventArgs>(null); 

     var observable = GetCommunicatorObservableForPushMessageReceived(communicator); 
     return observable 
      .Where(i => i.GetRequestFromReceivedMessage().Name == requestName) 
      .Select(i => i) 
      .FirstAsync() 
      .ToTask(); 
    } 

nơi GetCommunicatorObservableForPushMessageReceived() là:

static IObservable<MessageResponseEventArgs> GetCommunicatorObservableForPushMessageReceived(ICommunicator communicator) 
    { 
     if (communicatorObservableForPushMessageReceived == null) 
     { 
      communicatorObservableForPushMessageReceived = Observable 
       .FromEventPattern<MessageResponseEventArgs>(communicator, "PushMessageRecieved") 
       .Where(i => !IsPreviousMessage(i.EventArgs.GetRequestFromReceivedMessage().EventId)) 
       .Select(i => i.EventArgs); 
     } 

     return communicatorObservableForPushMessageReceived; 
    } 

Cập nhật: gì là hơi khủng khiếp là thế này (nhưng nó hoạt động) :

public static Task<MessageResponseEventArgs> HandlePushMessageRecievedAsync(this ICommunicator communicator, RequestName requestName) 
{ 
    if (communicator == null) return Task.FromResult<MessageResponseEventArgs>(null); 

    var completionSource = new TaskCompletionSource<MessageResponseEventArgs>(); 

    Observable 
     .FromEventPattern<MessageResponseEventArgs>(communicator, "PushMessageRecieved") 
     .Where(i => i.EventArgs.GetRequestFromReceivedMessage().Name == requestName) 
     .Select(i => i.EventArgs) 
     .ToEvent().OnNext += (args) => 
     { 
      if (args.Response.Errors != null && args.Response.Errors.Any()) 
      { 
       completionSource.TrySetException(args.Response.Errors.Select(j => new Exception(j.ErrorMessage))); 
      } 
      else 
      { 
       completionSource.TrySetResult(args); 
      } 
     }; 

    return completionSource.Task; 
} 

Answer 1

Cả hai RunAsync và ToTask sản lượng giá trị cuối cùng có thể quan sát được. Do đó, không có giá trị nào được tạo cho đến khi có thể quan sát được hoàn thành. Nhưng các quan sát được tạo ra với FromEventPattern thường không hoàn thành. Bạn cần buộc họ hoàn thành một số thứ như Take hoặc Until.

Tôi cũng sẽ lưu ý rằng RunAsync và ToTask về bản chất là không cần thiết và không cần phải thực hiện cả hai.

Trong trường hợp của bạn, tôi sẽ giả sử bạn đang thực sự quan tâm đến các giá trị đầu tiên mà làm cho nó thông qua bộ lọc của bạn:

var task = Observable 
    .FromEventPattern<MessageResponseEventArgs>(communicator, "PushMessageRecieved") 
    .FirstAsync(i => i.EventArgs.GetRequestFromReceivedMessage().Name == requestName) 
    .Select(i => i.EventArgs) 
    .ToTask(); 

task.Wait(); 

Answer 2

Các trình xử lý cho sự kiện PushMessageRecieved mà bạn đang quan sát cần được chạy trên luồng giao diện người dùng, trong bối cảnh đồng bộ hóa hiện tại. Bạn đang chặn chuỗi giao diện người dùng (đại diện cho ngữ cảnh hiện tại) trong khi bạn đợi tác vụ này. Nhiệm vụ không thể hoàn thành bởi vì bạn đang chờ đợi nó, bạn sẽ không bao giờ kết thúc chờ đợi vì nó không thể chạy. Deadlock.

Bạn không nên đồng bộ chặn trên tác vụ mà thực thi mã không đồng bộ như là sự tiếp tục của tác vụ đó.