Reactivex - rxjs healp

Bom kar tl;dr verzijo napisal; za svoj hobi projekt se igram z rxjs. Ker bi rad videl rezultate cim prej, uprabljam ract in promise, rxjs pa uvajam postopoma in se ga zdraven ucim. Trenutno me zanima, kako bi pravilno resil sledec problem filtriranja: imam observable, kjer dobivam tekstovni filter in funkcijo, kamor lahko ta filter posljem in ki vrne promise, ki resolva z rezultati.
Torej nekaj takega:

filter$ // filter$.subscribe(console.log) ze izpisuje text, ki ga vpisujem v nek input
const search = (filter) => Promise.resolve(['resultat1', 'rezultat2']) // psevdo primer filter funkcije

Sedaj bi rad dobil stream, ki se obesi na filter$, poslje filter v search funkcijo in na koncu 'vraca' kot rezultat objekt z filter tekstom in rezultati, nekaj v tem smislu:

results$ = ???

results$.subscribe(
  console.log, // onNext
  noop, // onError
  noop // onComplete
)
// bi izpisoval: { filter: 'filter text', results: ['rezultat1', 'rezultat2'] }
// Kar je se pomembno, je, da se ta results$ ne bi koncal, se pravi, ne bi se klical onComplete, ampak onNext handler vsakic, ko bi filter$ dobil novo vrednost.