Multiple named queries that produce their own stream

I would like to extend a source to have multiple named queries that produce their own stream.
Can you please give me correct direction on how to achieve this?
Or reference to anything similar that is implemented before?