Rx Observable có thể xử lý ngoại lệ một cách duyên dáng trong một toán tử và tiếp tục không?

Question

tức là, bằng cách chuyển điều kiện lỗi và không dừng toàn bộ Chế độ có thể quan sát?

Quan sát của tôi bắt đầu bằng danh sách số theo dõi gói do người dùng cung cấp từ các dịch vụ chuyển phát thường (FedEx, UPS, DHL, v.v.), tra cứu ngày giao hàng dự kiến ​​trực tuyến, sau đó trả về ngày đó theo số ngày từ hôm nay (nghĩa là "trong 3 ngày" thay vì "ngày 22 tháng 1"). Vấn đề là nếu bất kỳ tra cứu cá nhân nào dẫn đến một ngoại lệ, toàn bộ luồng sẽ dừng và phần còn lại của các mã sẽ không được tra cứu. Không có khả năng xử lý một cách duyên dáng, ví dụ: UnknownTrackingCode Exception và vì vậy Đài quan sát không thể đảm bảo rằng nó sẽ tra cứu tất cả các mã mà người dùng đã gửi.

public void getDaysTillDelivery(List<String> tracking_code_list) { 
     Observable o = Observable.from(tracking_code_list) 
        // LookupDeliveryDate performs network calls to UPS, FedEx, USPS web sites or APIs 
        // it might throw: UnknownTrackingCode Exception, NoResponse Exception, LostPackage Exception 
       .map(tracking_code -> LookupDeliveryDate(tracking_code)) 
       .map(delivery_date -> CalculateDaysFromToday(delivery_date)); 
     o.subscribe(mySubscriber); // will handle onNext, onError, onComplete 
} 

Ngăn chặn dòng Quan sát là kết quả của một lỗi là do thiết kế:

• http://reactivex.io/documentation/operators/catch.html
• Handling Exceptions in Reactive Extensions without stopping sequence
• https://groups.google.com/forum/#!topic/rxjava/trm2n6S4FSc

Hành vi mặc định có thể được khắc phục , nhưng chỉ bằng cách loại bỏ rất nhiều các lợi ích của Rx ở nơi đầu tiên:

• tôi có thể quấn LookupDeliveryDate để nó trả về Ngày thay Exceptions (như 1899-12-31 cho UnknownTrackingCode Exception) nhưng điều này ngăn cản "mã lỏng lẻo", bởi vì CalculateDaysFromToday sẽ cần phải xử lý những trường hợp đặc biệt
• tôi có thể bao quanh mỗi chức năng ẩn danh với try/catch và khối, nhưng điều này chủ yếu ngăn cản tôi từ việc sử dụng lambdas
• tôi có thể sử dụng if/thens chỉ đạo con đường mã, nhưng điều này sẽ có khả năng đòi hỏi phải duy trì một số nhà nước và loại bỏ đánh giá xác định
• Lỗi xử lý từng bước, rõ ràng, ngăn củng cố tất cả các lỗi xử lý trong Subscriber
• Viết điều hành lỗi xử lý riêng của tôi là có thể, nhưng mỏng ghi

Có cách nào tốt hơn để xử lý này?

Answer 1

Chính xác bạn muốn điều gì xảy ra nếu có lỗi? Bạn chỉ muốn ném mục đó đi hay bạn muốn thứ gì đó hạ lưu để làm điều gì đó với nó?

Nếu bạn muốn thứ gì đó hạ lưu để thực hiện một số hành động, thì bạn thực sự chuyển lỗi thành dữ liệu (ví dụ như ví dụ về trả về giá trị được gửi là 1899-12-31 để trình bày lỗi). Chiến lược này theo định nghĩa có nghĩa là mọi thứ ở hạ lưu cần phải hiểu rằng luồng dữ liệu có thể chứa lỗi thay vì dữ liệu và chúng phải được sửa đổi để xử lý nó.

Nhưng thay vì tạo ra giá trị phép thuật, bạn có thể biến luồng Observable của mình thành luồng giá trị Either. Giá trị là ngày hoặc đó là lỗi. Mọi thứ ở hạ lưu nhận đối tượng Either này và có thể hỏi nó nếu nó có giá trị hoặc lỗi.Nếu nó có giá trị, chúng có thể tạo ra đối tượng Either mới với kết quả tính toán của chúng. Nếu nó có lỗi và họ không thể làm bất cứ điều gì với nó, họ có thể mang lại một lỗi Hoặc là chính họ.

Tôi không biết cú pháp Java, nhưng đây là những gì nó có thể trông giống như trong C#:

Observable.From(tracking_code_list) 
    .Select(t => 
     { 
      try { return Either.From(LookupDeliveryDate(t)); } 
      catch (Exception e) 
      { 
       return Either.FromError<Date>(e); 
      } 
     }) 
    .Select(dateEither => 
     { 
      return dateEither.HasValue ? 
       Either.From(CalculateDaysFromToday(dateEither.Value)) : 
       Either.FromError<int>(dateEither.Error); 
     }) 
    .Subscribe(value => 
     { 
      if (value.HasValue) mySubscriber.OnValue(value.Value); 
      else mySubscribe.OnError(value.Error); 
     }); 

tùy chọn khác của bạn là "xử lý"/ngăn chặn các lỗi khi nó xảy ra. Điều này có thể đủ tùy thuộc vào nhu cầu của bạn. Trong trường hợp này, chỉ cần có LookupDeliveryDate ngày ma thuật trả về thay vì ngoại lệ và sau đó thêm .filter để lọc ra các ngày kỳ diệu trước khi chúng đến được CalculateDaysFromToay.