[ 
https://issues.apache.org/jira/browse/ARROW-10183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17209498#comment-17209498
 ] 

Weston Pace commented on ARROW-10183:
-------------------------------------

I had not quite come across that class so I appreciate the mention.  It will 
not satisfy in this case though.  There is a back pressure problem that is 
difficult to explain but will make more sense in code.

More significantly though, the AsCompletedIterator still does waits, which is 
what I'm trying to avoid.  I'm attaching a diagram to this sub task that will 
hopefully provide a bit more explanation.

> Create a ForEach library function that runs on an iterator of futures
> ---------------------------------------------------------------------
>
>                 Key: ARROW-10183
>                 URL: https://issues.apache.org/jira/browse/ARROW-10183
>             Project: Apache Arrow
>          Issue Type: Sub-task
>          Components: C++
>            Reporter: Weston Pace
>            Priority: Major
>         Attachments: arrow-continuation-flow.jpg
>
>
> This method should take in an iterator of futures and a callback and pull an 
> item off the iterator, "await" it, run the callback on it, and then fetch the 
> next item from the iterator.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to