在rxjs5中，我有一个AsyncSubject并想多次订阅它，但只有一个订阅者应该收到next()事件。所有其他人(如果他们尚未取消订阅)应立即获得complete()事件，而无需next()。例子:letfired=false;letas=newAsyncSubject();constsetFired=()=>{if(fired==true)thrownewError("Multiplesubscriptionsexecuted");fired=true;}letsubscription1=as.subscribe(setFired);letsubscription2=as.sub