Method pulls elements from stream and returns task that:

- fails if stream is finished

- completes with None in case if stream is completed after we got task

- completes with `Some(element)` in case next element is available from stream.