open_in_new
content_copy
data$.pipe() mergeMap(data => fireObsMethodOnEachObsEmmision) fireObsMethodOnEachObsEmmision$ -> obs