source.link_target(&on_next_);
}
- std::shared_ptr<void> get_prenumeration_token(
+ std::shared_ptr<void> get_subscription_token(
const boost::asio::ip::udp::endpoint& endpoint)
{
tbb::spin_mutex::scoped_lock lock(endpoints_mutex_);
{
}
-std::shared_ptr<void> client::get_prenumeration_token(
+std::shared_ptr<void> client::get_subscription_token(
const boost::asio::ip::udp::endpoint& endpoint)
{
- return impl_->get_prenumeration_token(endpoint);
+ return impl_->get_subscription_token(endpoint);
}
}}}
client(client&&);
/**
- * Get a prenumeration token that ensures that OSC messages are sent to the
+ * Get a subscription token that ensures that OSC messages are sent to the
* given endpoint as long as the token is alive. It will stop sending when
* the token is dropped unless another token to the same endpoint has
* previously been checked out.
*
* @return The token. It is ok for the token to outlive the client
*/
- std::shared_ptr<void> get_prenumeration_token(
+ std::shared_ptr<void> get_subscription_token(
const boost::asio::ip::udp::endpoint& endpoint);
~client();
std::vector<safe_ptr<IO::AsyncEventServer>> async_servers_; \r
std::shared_ptr<IO::AsyncEventServer> primary_amcp_server_;\r
osc::client osc_client_;\r
- std::vector<std::shared_ptr<void>> predefined_osc_prenumerations_;\r
+ std::vector<std::shared_ptr<void>> predefined_osc_subscriptions_;\r
std::vector<safe_ptr<video_channel>> channels_;\r
std::shared_ptr<thumbnail_generator> thumbnail_generator_;\r
\r
{ \r
ffmpeg::uninit();\r
\r
- async_servers_.clear();\r
primary_amcp_server_.reset();\r
+ async_servers_.clear();\r
channels_.clear();\r
}\r
\r
predefined_client.second.get<std::wstring>(L"address");\r
const auto port =\r
predefined_client.second.get<unsigned short>(L"port");\r
- predefined_osc_prenumerations_.push_back(\r
- osc_client_.get_prenumeration_token(udp::endpoint(\r
+ predefined_osc_subscriptions_.push_back(\r
+ osc_client_.get_subscription_token(udp::endpoint(\r
address_v4::from_string(narrow(address)),\r
port)));\r
}\r
{\r
using namespace boost::asio::ip;\r
\r
- return osc_client_.get_prenumeration_token(\r
+ return osc_client_.get_subscription_token(\r
udp::endpoint(\r
address_v4::from_string(ipv4_address),\r
default_port));\r