О, я понимаю, вы правы, оператор обмена здесь не подходит, вы можете использовать публикацию и метод connect или reply (). RefCount ()
мер,
заданный поток определенного числа (m) чисел (m1, m2, m3, m4, m5, m6 ...), и применить преобразование (2 * i) к первым n элементам (n может быть меньше, равно или больше, чем m), примените другое преобразование (3 * i) к оставшимся элементам. а также
возвращаемый результат: m1 * 2, m2 * 2, m3 * 3, m4 * 3, m5 * 3, m6 * 3 ... (при условии n = 2 здесь).
Я пытался использовать take (n) и skip (n), а затем concatwith, но похоже, что take (n) отбросит оставшиеся элементы в последовательности и сделает skip (n) после этого ничего не возвращает.