thiscodeWorks - Organizing the best of code online

List view

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

fireObsMethodOnEachObsEmmision$ -> obs

#webaudioapi #tonejs

RXJS save operations - concatMap-operator

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

#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

Audio Buffer

# get audioBuffer from context

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

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

#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

Analyzer Wafeform

mic.connect(analyzer)

RXJS non-sequential mergeMap

RXJS save operations - concatMap-operator

Reactive RXJS derive multiple streams

Audio Buffer

Tone Audio Context

Analyzer Wafeform

Save snippets that work with our extensions