Генератор, как поток от RxJS от JS Map

Я не тестировал его, но есть метод bindNodeCallback , который обертывает функцию узла и возвращает другую функцию, возвращающую Observables. Затем concatMap не будет обрабатывать новый элемент до тех пор, пока не будет завершен текущий внутренний Observable.

Итак, в вашем случае использования вы можете использовать, например, следующее:

const obsWrite = bindNodeCallback(client.write);

source
  .pipe(
    map((x: any) => x.join('')),
    concatMap((x: string) => obsWrite(x))
  )
  .subscribe();