WIP on #15086 cancelling processors/subscribers if they are never consumed