import { asapScheduler , of , range , generate } from 'rxjs' ; const source1$ = of ( 1 , 2 , 3 ) ; const source2$ = of ( 1 , 2 , 3 , asapScheduler ) ; const observer = ( id ) => { return { next : ( x ) => console . log ( `ID ${ id } Next: ${ x }` ) , complete : ( ) => console . log ( `ID ${ id } Complete!` ) } ; } ; const range1$ = range ( 0 , 3 ) ; const range2$ = range ( 3 , 3 ) ; const number$ = generate ( 43 , i => i < 46 , i => i + 1 , i => String . fromCharCode ( i ) ) ; const subscription = number$ . subscribe ( { next : x => console . log ( `Next: ${ x }` ) , complete : ( ) => console . log ( `Complete!` ) } ) ;