cavinkwon / futre_channel_in_rb Goto Github PK

일단 안정버전의

concurrent-ruby을 사용하여

api = ->param{ param == 4 ? raise : param }
jobs = 4.times.map{ |i| Concurrent::Promise.execute{ api.call(i) } }
Concurrent::Promise.zip(*jobs).value #=> [0, 1, 2, 3]

jobs = 5.times.map{ |i| Concurrent::Promise.execute{ api.call(i) } }
Concurrent::Promise.zip(*jobs).value #=> nil

위와 같은 결과를 얻을 수 있는데요,

Concurrent::Promise#zip의 [문서]에

Builds a promise that produces the result of promises in an Array and fails if any of them fails.

위와 같이 나와있는것을 확인하였습니다.

zip을 호출하면서 넘긴 *promises에 어떤것이라도 실패하면 zip의 리턴이 nil이 되는것 자체는 정상동작인것은 알겠는데,

제가 원하는건 exception이 발생하였더라도,

Concurrent::Promise.zip(*jobs).value #=> [0, 1, 2, 3, RuntimeError]

이런식으로라도.. 성공한 Promise의 value는 받고싶은데... 방법이 없을까요..?

써주신 문서의 에러 핸들링부분을 보면 concurrent-edge의 Concurrent.future와 Concurrent.zip을 통해서 제가 원하는 결과가 보이긴 하는데

제가 원하는대로 하려면 concurrent-edge를 꼭 사용해야하나요? 안정버전에서는 방법이 없을까요?

좋은글 감사합니다.