проблема в том, что когда вы подписываетесь на valueChanges(), он становится горячим наблюдаемым и никогда не завершается, поэтому вы не можете получить желаемый результат - как поток должен знать, когда все номер задания 1 прибыл? Некоторые обходные пути могут быть сделаны, хотя, например. добавьте timeout и с помощью scan соберите все значения в темах аккумулятора и т. д., затем объедините их и произведите.
Но имеет ли смысл, если вы уже храните все данные локально? Возможно нет. ИМО, вы можете работать с ответом только после его получения, например создавать предметы и в зависимости от job number 1 звонить next() на них.