tcp.hpp

Go to the documentation of this file.

/*------------------------------------------------------------------------------
    Copyright Butterfly Energy Systems 2014-2015, 2022.
    Distributed under the Boost Software License, Version 1.0.
    http://www.boost.org/LICENSE_1_0.txt
------------------------------------------------------------------------------*/
 
#ifndef CPPWAMP_TCP_HPP
#define CPPWAMP_TCP_HPP
 
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
 
#include <cassert>
#include <memory>
#include <string>
#include <utility>
#include "api.hpp"
#include "asiodefs.hpp"
#include "connector.hpp"
#include "tcphost.hpp"
#include "traits.hpp"
 
#ifndef CPPWAMP_COMPILED_LIB
    #include "internal/asioconnector.hpp"
    #include "internal/rawsockconnector.hpp"
    #include "internal/tcpopener.hpp"
#endif
 
namespace wamp
{
 
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
template <typename TCodec>
CPPWAMP_API Connector::Ptr connector(
    AnyIoExecutor exec, 
    TcpHost host      
);
 
#ifndef CPPWAMP_COMPILED_LIB
template <typename TCodec>
Connector::Ptr connector(AnyIoExecutor exec, TcpHost host)
{
    using Endpoint = internal::AsioConnector<internal::TcpOpener>;
    using ConcreteConnector = internal::RawsockConnector<TCodec, Endpoint>;
    return ConcreteConnector::create(exec, std::move(host));
}
#endif
 
 
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
template <typename TCodec, typename TExecutionContext>
CPPWAMP_ENABLED_TYPE(Connector::Ptr, isExecutionContext<TExecutionContext>())
connector(
    TExecutionContext& context, 
    TcpHost host                
)
{
    return connector<TCodec>(context.get_executor(), std::move(host));
}
 
} // namespace wamp
 
#endif // CPPWAMP_TCP_HPP