libs/rpc/include/mace/rpc/connection_base.hpp

#ifndef _MACE_RPC_CONNECTION_BASE_HPP_
#define _MACE_RPC_CONNECTION_BASE_HPP_
#include <boost/function.hpp>
#include <mace/rpc/message.hpp>
#include <mace/rpc/detail/pending_result.hpp>

namespace mace { namespace rpc  {

  typedef boost::function<message(const message&)> method;

  namespace detail { class connection_base; }
  
  class connection_base : public boost::noncopyable {
    public:
      ~connection_base();

      const method* get_method( const std::string& name )const;

      void          add_method( const std::string& name, const method& );

      std::string   add_method( const method& m );

      cmt::future<datavec> raw_call( std::string&& mid, datavec&& param );

      std::string create_method_id();

      connection_base& operator=( connection_base&& m ) {
        std::swap(m.my,my);
        return *this;
      }

    protected:
      void raw_call( std::string&& meth, datavec&& param, 
                     const detail::pending_result::ptr& pr );

      connection_base( detail::connection_base* b );
      connection_base( connection_base&& m ):my(m.my) { m.my=0; }

      detail::connection_base* my;
    private:
      connection_base();
  };


} }  // namespace mace::rpc

#endif // _MACE_RPC_CONNECTION_BASE_HPP_