http$ = from(src)

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

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