ProcessCommunicationChannel.h

#pragma once
 
#include <EditorEngineProcessFramework/EditorEngineProcessFrameworkDLL.h>
#include <Foundation/Communication/Event.h>
#include <Foundation/Time/Time.h>
#include <Foundation/Types/Delegate.h>
#include <Foundation/Types/UniquePtr.h>
 
class plIpcChannel;
class plProcessMessage;
class plIpcProcessMessageProtocol;
 
class PL_EDITORENGINEPROCESSFRAMEWORK_DLL plProcessCommunicationChannel
{
public:
  plProcessCommunicationChannel();
  ~plProcessCommunicationChannel();
 
  bool SendMessage(plProcessMessage* pMessage);
 
  using WaitForMessageCallback = plDelegate<bool(plProcessMessage*)>;
  plResult WaitForMessage(const plRTTI* pMessageType, plTime timeout, WaitForMessageCallback* pMessageCallack = nullptr);
  plResult WaitForConnection(plTime timeout);
  bool IsConnected() const;
 
  bool ProcessMessages();
  void WaitForMessages();
 
  struct Event
  {
    const plProcessMessage* m_pMessage;
  };
 
  plEvent<const Event&> m_Events;
 
  void MessageFunc(const plProcessMessage* pMsg);
 
protected:
  plUniquePtr<plIpcProcessMessageProtocol> m_pProtocol;
  plUniquePtr<plIpcChannel> m_pChannel;
  const plRTTI* m_pFirstAllowedMessageType = nullptr;
 
private:
  WaitForMessageCallback m_WaitForMessageCallback;
  const plRTTI* m_pWaitForMessageType = nullptr;
};