Compare commits

...
3 Commits
Author SHA1 Message Date
jinchao 6cb33384fe Merge branch 'master' of https://git.thecodeway.com/jinchao/TurboLinkTest 2023-03-25 15:50:34 +08:00
jinchao a16136bd0e 使用新接口 2023-03-25 15:48:16 +08:00
jinchao c43443d737 使用新接口 2023-03-25 15:46:33 +08:00
4 changed files with 5 additions and 14 deletions
@@ -65,7 +65,7 @@ void UTimeTestWidget::UpdateControlState()
void UTimeTestWidget::OnConnectServiceButtonClicked() void UTimeTestWidget::OnConnectServiceButtonClicked()
{ {
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"));
@@ -93,7 +93,7 @@ void UTimeTestWidget::OnShutdownServiceButtonClicked()
} }
TimeService->OnServiceStateChanged.RemoveDynamic(this, &UTimeTestWidget::OnTimeServiceStateChanged); TimeService->OnServiceStateChanged.RemoveDynamic(this, &UTimeTestWidget::OnTimeServiceStateChanged);
UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager()->ReleaseService(TimeService); UTurboLinkGrpcUtilities::GetTurboLinkGrpcManager(this)->ReleaseService(TimeService);
TimeService = nullptr; TimeService = nullptr;
UpdateControlState(); UpdateControlState();
@@ -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;
}; };