Thanks.

The purpose of prioritize is to facilitate the creation a notification observable from a source stream, so that the observable can be used to buffer and window the source stream based upon its own contents.

The source for prioritize is here and there is a test here that should show what I mean.

I’m planning on writing an article about creating signalling/notification streams sometime in the, hopefully, not too distant future.