Calling to `flowable` store's extension create a new `PublishProcessor` each time. Shouldn't the extension provide an unique instance for each Store? This is a big problem on doing one shots operations, despite of `takeUntil` Rx`s operator store keep hold each listener.