Reactive RXJS derive multiple streams

PHOTO

Wed Jun 29 2022 14:26:35 GMT+0000 (Coordinated Universal Time)

http$ = from(src)

response$ = http$.pipe().map() // translate the response 

// consume translated response
1$ = response$.pipe().map() 
2$ = response$.pipe().map()

COPY

Save snippets that work from anywhere online with our extensions

Comments

NG

@Polly

Reactive RXJS derive multiple streams RXJS save operations - concatMap-operator RXJS non-sequential mergeMap RXJS custom operator RXJS cancel-restart observable on new data - switchMap RXJS Error Handling RXJS forkJoin - combine multiple obs to separate outputs - RXJS withLatestFrom RXJS Behavior Subject

#webaudioapi #tonejs

Analyzer Wafeform

mic.connect(analyzer)

#webaudioapi #tonejs

Tone Audio Context

context = new Tone.context

### Examples

# Destination inputNodes 

## gets PCM data from stream/file and returns small segments at a time 
context.decodeAudioData(audioData:ArrayBuffer) -> returns AudioBuffer 



# Source outputNodes to play audio streams/files

## creates html controls for the input passed to it.
context.createMediaElementSource() -> returns <audio>

#webaudioapi #tonejs

Audio Buffer

# get audioBuffer from context

context.decodeAudioData( inputAudioDataFromDestination, (audioData:ArrayBuffer) -> play(audioBuffer) )

sourceNode = context.createBufferSource()
audioBufferSource = sourceNode.buffer
play(audioBufferSource)

#webaudioapi #tonejs

Reactive RXJS derive multiple streams

http$ = from(src)

response$ = http$.pipe().map() // translate the response 

// consume translated response
1$ = response$.pipe().map() 
2$ = response$.pipe().map()

#webaudioapi #tonejs

RXJS save operations - concatMap-operator

form.valueChanges.pipe()
	concatMap(changes => returnObservalbeToConcatMap())

#webaudioapi #tonejs

RXJS non-sequential mergeMap

data$.pipe()
	mergeMap(data => fireObsMethodOnEachObsEmmision)

fireObsMethodOnEachObsEmmision$ -> obs

Reactive RXJS derive multiple streams

Save snippets that work from anywhere online with our extensions

Comments

More like this

NG

Browse more snippets >>

Reactive RXJS derive multiple streams

Save snippets that work from anywhere online with our extensions

Comments

More like this

NG

Browse more snippets >>

Embed code snippet