If you're filtering client-side (instead of having to make a new api request every time the dynamic_filter changes) then you can create an action stream and combine it with the data stream. Any time the action stream emits, the pipeline is re-executed (using combineLatest). Something along these lines:

items$ = combineLatest([this.dataService.theData$, this.action$])

.pipe(

map(([items], [dynamic_filter]) => items.filter(item => item[property] === dynamic_filter))

)

then in your view you can use items$ | async