1- import { OperatorDoc } from " ../operator.model" ;
1+ import { OperatorDoc } from ' ../operator.model' ;
22
33export const merge : OperatorDoc = {
4- name : " merge" ,
5- operatorType : " combination" ,
4+ name : ' merge' ,
5+ operatorType : ' combination' ,
66 signature :
7- " public merge(other: ObservableInput, concurrent: number, scheduler: Scheduler): Observable" ,
7+ ' public merge(other: ObservableInput, concurrent: number, scheduler: Scheduler): Observable' ,
88 parameters : [
99 {
10- name : " other" ,
11- type : " ObservableInput" ,
12- attribute : "" ,
10+ name : ' other' ,
11+ type : ' ObservableInput' ,
12+ attribute : '' ,
1313 description : `An input Observable to merge with the source Observable. More than one input
1414 Observables may be given as argument.`
1515 } ,
1616 {
17- name : " concurrent" ,
18- type : " number" ,
19- attribute : " optional, default: Number.POSITIVE_INFINITY" ,
17+ name : ' concurrent' ,
18+ type : ' number' ,
19+ attribute : ' optional, default: Number.POSITIVE_INFINITY' ,
2020 description : `Maximum number of input Observables being subscribed to concurrently.`
2121 } ,
2222 {
23- name : " scheduler" ,
24- type : " Scheduler" ,
25- attribute : " optional, default: null" ,
23+ name : ' scheduler' ,
24+ type : ' Scheduler' ,
25+ attribute : ' optional, default: null' ,
2626 description : `The IScheduler to use for managing concurrency of input Observables.`
2727 }
2828 ] ,
29- marbleUrl : " http://reactivex.io/rxjs/img/merge.png" ,
29+ marbleUrl : ' http://reactivex.io/rxjs/img/merge.png' ,
3030 shortDescription : {
3131 description : `Creates an output Observable which concurrently emits all values
3232 from every given input Observable. <span class="informal">Flattens multiple Observables
3333 together by blending their values into one Observable.</span>`
3434 } ,
3535 walkthrough : {
3636 description : `
37- <p><code>Merge</code > subscribes to each given input Observable (either the source or an
37+ <p><span class="markdown- code" >Merge</span > subscribes to each given input Observable (either the source or an
3838 Observable given as argument), and simply forwards (without doing any
3939 transformation) all the values from all the input Observables to the output
4040 Observable. The output Observable only completes once all input Observables
@@ -44,20 +44,20 @@ export const merge: OperatorDoc = {
4444 } ,
4545 examples : [
4646 {
47- name : " Merge together two Observables: 1s interval and clicks" ,
47+ name : ' Merge together two Observables: 1s interval and clicks' ,
4848 code : `
4949 const clicks = Rx.Observable.fromEvent(document, 'click');
5050 const timer = Rx.Observable.interval(1000);
5151 const clicksOrTimer = clicks.merge(timer);
5252 clicksOrTimer.subscribe(x => console.log(x));
5353 ` ,
5454 externalLink : {
55- platform : " JSBin" ,
56- url : " http://jsbin.com/wihafapiva/1/edit ?js,output"
55+ platform : ' JSBin' ,
56+ url : ' http://jsbin.com/wihafapiva/1/embed ?js,output'
5757 }
5858 } ,
5959 {
60- name : " Merge together 3 Observables, but only 2 run concurrently" ,
60+ name : ' Merge together 3 Observables, but only 2 run concurrently' ,
6161 code : `
6262 const timer1 = Rx.Observable.interval(1000).take(10);
6363 const timer2 = Rx.Observable.interval(2000).take(6);
@@ -67,10 +67,10 @@ export const merge: OperatorDoc = {
6767 merged.subscribe(x => console.log(x));
6868 ` ,
6969 externalLink : {
70- platform : " JSBin" ,
71- url : " http://jsbin.com/midosuqaga/1/edit ?js,output"
70+ platform : ' JSBin' ,
71+ url : ' http://jsbin.com/midosuqaga/1/embed ?js,output'
7272 }
7373 }
7474 ] ,
75- relatedOperators : [ " mergeAll" , " mergeMap" , " mergeMapTo" , " mergeScan" ]
75+ relatedOperators : [ ' mergeAll' , ' mergeMap' , ' mergeMapTo' , ' mergeScan' ]
7676} ;
0 commit comments