我有一组要迭代的元素,每个元素都调用一个异步函数,然后等待它们全部完成(这再次以异步方式发生,在函数的逻辑中实现)。我对RxJava比较陌生,在NodeJS中很容易做到这一点,方法是将回调传递给函数并在函数结束时等待。下面是我需要的伪代码(元素的迭代器不需要是同步的也不是有序的): callAsyncFunction(line);WAIT FOR ALL OF THEM
我正在创建一个应用程序,其中用户可以拥有多个房间,每个房间可以有多个频道,以下是我在检索房间和相应频道时的代码: ]但是我总是得到一个空数组,因为async.each(rooms, function (roomId, cb){ })不等待async.each(channels, function (channelId, cb) {})完成,所以我有一个空的房间对象。