turi::neural_net::SubscribeOnQueuePublisher< T > Class Template Reference

#include <ml/neural_net/combine_queue.hpp>

Public Member Functions
void	Receive (std::shared_ptr< Subscriber< Output >> subscriber) override

Detailed Description

template<typename T>
class turi::neural_net::SubscribeOnQueuePublisher< T >

Publisher that implements the Publisher::SubscribeOn operator.

The resulting Publisher simply dispatches subscription requests, demands, and cancellations to a specified task queue. It inherits the semantics of the upstream Publisher that it wraps, with regard to the behavior with multiple downstream subscribers.

Definition at line 45 of file combine_base.hpp.

Member Function Documentation

Receive()

template<typename T >

void turi::neural_net::SubscribeOnQueuePublisher< T >::Receive ( std::shared_ptr< Subscriber< Output >>  subscriber )

inlineoverridevirtual

Establishes a connection between this Publisher and the given Subcriber.

The Publisher must eventually call Subscriber::Receive(Subscription) on the given Subscriber (and may do so synchronously). The Publisher must then conform to the protocol established by the Subscription.

Implements turi::neural_net::Publisher< T >.

Definition at line 43 of file combine_queue.hpp.

---

The documentation for this class was generated from the following files:

• ml/neural_net/combine_base.hpp
• ml/neural_net/combine_queue.hpp