Use groupBy in Real RxJS Applications

I'm trying to convert groups into arrays however because my source is using combineLatest with a search$ (filter) that does not complete, the groups cannot complete and I'm left using scan and partial groups that I cannot figure out how to get rid of.

If I had a websocket observable and I wanted different behavior for different values in the stream (some lines are directives that change app behavior others are simply data. Is groupBy the tool to use, or would it be better to create separate filtering observables to process the data coming from the stream?