SocketCreationSession.h

Go to the documentation of this file.

// Copyright (c) Fraunhofer MEVIS, Germany. All rights reserved.
// **InsertLicense** code
 
#pragma once
 
#include <asio/Signal.h>
#include <asio/Socket.h>
 
#include <FMEThirdPartyWarningsDisable.h>
#include <memory>
#include <utility>
#include <FMEThirdPartyWarningsRestore.h>
 
namespace asio {
 
  template<typename SessionType>
  class SocketCreationSession : public std::enable_shared_from_this<SessionType>
  {
  public:
 
    template<typename... Arguments>
    static std::shared_ptr<SessionType> create(Arguments&&... arguments)
    {
      return std::shared_ptr<SessionType>(new SessionType(std::forward<Arguments>(arguments)...));
    }
 
    template<typename Slot>
    SignalConnection observeConnectionEstablished(Slot&& slot)
    {
      return connectionEstablished.connect(std::forward<Slot>(slot));
    }
 
    template<typename Slot>
    SignalConnection observeErrorOccured(Slot&& slot)
    {
      return errorOccured.connect(std::forward<Slot>(slot));
    }
 
    template<typename Slot>
    SignalConnection observeAboutToBeDestroyed(Slot&& slot)
    {
      return aboutToBeDestroyed.connect(std::forward<Slot>(slot));
    }
 
    ~SocketCreationSession()
    {
      aboutToBeDestroyed();
    }
 
  protected:
 
    void emitConnectionEstablished(std::unique_ptr<Socket> socket)
    {
      connectionEstablished(socket);
    }
 
    void emitErrorOccured(const ErrorCode& ec)
    {
      errorOccured(ec);
    }
 
  private:
 
    Signal<void(std::unique_ptr<Socket>&)> connectionEstablished;
    Signal<void(const ErrorCode&)> errorOccured;
    Signal<void()> aboutToBeDestroyed;
  };
 
}