'Return samples produced by *process_notification*.
Samples produced for the given notification.
:param context: Execution context from the service or RPC call
:param notification: The notification to process.'

def to_samples_and_publish(self, notification):

    with self.manager.publisher() as p:
        p(list(self.process_notification(notification)))
