MessageRpcClient.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include "CoreTypes.h"
#include "Containers/Map.h"
#include "Delegates/IDelegateInstance.h"
#include "IMessageContext.h"
#include "IMessageRpcClient.h"
#include "Misc/Guid.h"
#include "Templates/SharedPointer.h"
#include "Containers/Ticker.h"
 
class FMessageEndpoint;
class IMessageBus;
class IMessageRpcCall;
 
struct FMessageRpcProgress;
struct FMessageEndpointBuilder;
 
 
class FMessageRpcClient
    : public IMessageRpcClient
{
public:
 
    FMessageRpcClient();
    FMessageRpcClient(const FString& InDebugName, const TSharedRef<IMessageBus, ESPMode::ThreadSafe>& InMessageBus);
    
    virtual ~FMessageRpcClient();
 
public:
 
    //~ IMessageRpcClient interface
 
    virtual void Connect(const FMessageAddress& InServerAddress) override;
    virtual void Disconnect() override;
    virtual bool IsConnected() const override;
 
protected:
    explicit FMessageRpcClient(FMessageEndpointBuilder&& InEndpointBuilder);
 
    TSharedPtr<IMessageRpcCall> FindCall(const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
    void SendCall(const TSharedPtr<IMessageRpcCall>& Call);
 
protected:
 
    //~ IMessageRpcClient interface
 
    virtual void AddCall(const TSharedRef<IMessageRpcCall>& Call) override;
    virtual void CancelCall(const FGuid& CallId) override;
 
private:
 
    void HandleProgressMessage(const FMessageRpcProgress& Message, const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
    void HandleRpcMessages(const TSharedRef<IMessageContext, ESPMode::ThreadSafe>& Context);
 
    bool HandleTicker(float DeltaTime);
 
private:
 
    TMap<FGuid, TSharedPtr<IMessageRpcCall>> Calls;
 
    TSharedPtr<FMessageEndpoint, ESPMode::ThreadSafe> MessageEndpoint;
 
    FMessageAddress ServerAddress;
 
    FTSTicker::FDelegateHandle TickerHandle;
};