create a processing element that is active only if consumers of results are subscribed to it