使用新接口

This commit is contained in:
2023-03-25 15:46:33 +08:00
parent 5f27665b73
commit c43443d737
3 changed files with 3 additions and 12 deletions
@@ -30,7 +30,7 @@ void ATurboLinkTestController::GetLifetimeReplicatedProps(TArray <FLifetimePrope
void ATurboLinkTestController::ConnectToTimeService_Implementation() void ATurboLinkTestController::ConnectToTimeService_Implementation()
{ {
if (TimeService != nullptr) return; if (TimeService != nullptr) return;
UTurboLinkGrpcManager* turboLinkManager = UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager(); UTurboLinkGrpcManager* turboLinkManager = UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager(this);
//create service adapter //create service adapter
TimeService = Cast<UTimeService>(turboLinkManager->MakeService("TimeService")); TimeService = Cast<UTimeService>(turboLinkManager->MakeService("TimeService"));
@@ -58,7 +58,7 @@ void ATurboLinkTestController::ShutdownTimeService_Implementation()
} }
TimeService->OnServiceStateChanged.RemoveDynamic(this, &ATurboLinkTestController::OnTimeServiceStateChanged); TimeService->OnServiceStateChanged.RemoveDynamic(this, &ATurboLinkTestController::OnTimeServiceStateChanged);
UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager()->ReleaseService(TimeService); UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager(this)->ReleaseService(TimeService);
TimeService = nullptr; TimeService = nullptr;
bIsClientCreated = false; bIsClientCreated = false;
@@ -8,16 +8,11 @@
void UTurboLinkTestGameInstance::Init() void UTurboLinkTestGameInstance::Init()
{ {
Super::Init(); Super::Init();
TurboLinkManager = UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager();
TurboLinkManager->InitManager();
} }
void UTurboLinkTestGameInstance::Shutdown() void UTurboLinkTestGameInstance::Shutdown()
{ {
// Unregister ticker delegate Super::Shutdown();
TurboLinkManager->Shutdown();
TurboLinkManager = nullptr;
} }
FString UTurboLinkTestGameInstance::DumpBytes(const FBytes& Bytes) FString UTurboLinkTestGameInstance::DumpBytes(const FBytes& Bytes)
@@ -25,8 +25,4 @@ public:
void DumpMessage(const FGrpcUserRegisterRequest& Message); void DumpMessage(const FGrpcUserRegisterRequest& Message);
protected: protected:
FString DumpBytes(const FBytes& Bytes); FString DumpBytes(const FBytes& Bytes);
protected:
UPROPERTY()
UTurboLinkGrpcManager* TurboLinkManager;
}; };