rxjs6 Трубопровод двух наблюдаемых дает подписку не является функцией

Question

rxjs 6.2.1

Я получаю ClusterStreams__.a.subscribe is not a function

Я пытаюсь передать результаты getClusterArns() в describeClusters() с кодом ниже ...

function getClusterArns() {
        const ecs = new AWS.ECS();
        return ecs.listClusters().promise();
}

function describeClusters(clusterArns) {
    const params = { clusters: clusterArns };
        const ecs = new AWS.ECS();
        return ecs.describeClusters(params).promise();
}


export const ClusterArnStream = from(getClusterArns());
export const ClusterStream = pipe(
  combineLatest(ClusterArnStream),
  mergeMap(([_, clusterArnsResponse]) => describeClusters(clusterArnsResponse.clusterArns)),
  map(x => x.clusters),
  multicast(() => new ReplaySubject(1))
);