Turi Create
4.0
|
#include <ml/neural_net/combine_iterator.hpp>
Public Member Functions | |
void | Receive (std::shared_ptr< Subscriber< Output >> subscriber) override |
Concrete Publisher that wraps an Iterator.
The resulting Publisher is unicast: each iterated value will go only to whichever Subscriber triggered the iteration.
Definition at line 21 of file combine_iterator.hpp.
|
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 94 of file combine_iterator.hpp.