def _queue(self):
        from notifications.models import NotificationQueue

        NotificationQueue.objects.create(
            user=self.user,
            subject=self.subject,
            text=self.text,
            send_at=self.send_at,
            notification_backend=self.__class__.__name__
        )
Execute a transducer to transform the observable sequence.
dataset/ETHPy150Open kevinrenskers/django-generic-notifications/notifications/backend/__init__.py/BaseNotificationBackend._queue--crossover with--dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/transduce.py/transduce