Có thể chuyển các cuộc gọi lại thành IEnumerable

Question

Tôi đang viết một trình bao bọc xung quanh một thư viện của bên thứ ba và nó có một phương pháp để quét dữ liệu mà nó quản lý. Phương thức này có một phương thức gọi lại mà nó gọi cho mỗi mục trong dữ liệu mà nó tìm thấy.

ví dụ: Phương pháp này về cơ bản là: void Scan(Action<object> callback);

Tôi muốn quấn nó và phơi bày một phương pháp như IEnumerable<object> Scan();

Đây có phải là có thể mà không cần đến một chủ đề riêng biệt để thực hiện quét thực tế và một bộ đệm?

Answer 1

Bạn có thể làm điều này khá đơn giản với phản ứng:

class Program 
{ 
    static void Main(string[] args) 
    { 
     foreach (var x in CallBackToEnumerable<int>(Scan)) 
      Console.WriteLine(x); 
    } 

    static IEnumerable<T> CallBackToEnumerable<T>(Action<Action<T>> functionReceivingCallback) 
    { 
     return Observable.Create<T>(o => 
     { 
      // Schedule this onto another thread, otherwise it will block: 
      Scheduler.Later.Schedule(() => 
      { 
       functionReceivingCallback(o.OnNext); 
       o.OnCompleted(); 
      }); 

      return() => { }; 
     }).ToEnumerable(); 
    } 

    public static void Scan(Action<int> act) 
    { 
     for (int i = 0; i < 100; i++) 
     { 
      // Delay to prove this is working asynchronously. 
      Thread.Sleep(100); 
      act(i); 
     } 
    } 
} 

Hãy nhớ rằng đây không chăm sóc những thứ như hủy bỏ, vì phương pháp gọi lại không thực sự cho phép nó. Một giải pháp thích hợp sẽ yêu cầu làm việc trên một phần của thư viện bên ngoài.

Answer 2

Hãy xem từ khóa yield - từ khóa này sẽ cho phép bạn có một phương thức trông giống như IEnumerable nhưng thực tế không xử lý cho từng giá trị trả về.