我的情况很简单，但是我似乎无法在任何地方找到它。
我有一组要迭代的元素，每个元素调用一个异步函数，然后等待所有元素完成（这又以异步方式发生，以函数的逻辑实现）。我对RxJava相对较新，过去曾在NodeJS中通过将回调传递给函数并在最后等待来轻松地做到这一点。这是我需要的伪代码（元素的迭代器不需要同步也不需要排序）：
for(line in lines){
callAsyncFunction(line);
}
WAIT FOR ALL OF THEM TO FINISH
非常感谢您的帮助！