LevelStreamingSubsystem.h

이 파일의 문서화 페이지로 가기

// Fill out your copyright notice in the Description page of Project Settings.
 
#pragma once
 
#include "CoreMinimal.h"
#include "Data/LevelStreamingData.h"
#include "Level/LevelStreamingDeque.h"
#include "Level/Effect/LevelStreamingEffect.h"
#include "Level/Effect/EffectChainExecutor.h"
#include "Level/CK_ELevelType.h"
#include "Data/Bundle/DataBundleRegistry.h"
#include "LevelStreamingSubsystem.generated.h"
 
class ULevelStreamingData;
class ULevelStreamingEffect;
class ULevelStreaming;
 
struct FLevelStreamingContext;
struct FLevelStreamingDeque;
 
 
DECLARE_DYNAMIC_MULTICAST_DELEGATE(FOnLevelLoadCompleted);
 
DECLARE_DYNAMIC_MULTICAST_DELEGATE_OneParam(FOnLevelLoadedInMemory, ULevelRuleData*, RuleData);
 
DECLARE_DYNAMIC_MULTICAST_DELEGATE_TwoParams(FOnPlacePlayerTheWorld, ULevelPlayerPlacer*, Placer, UWorld*, World);
 
 
 
UCLASS()
class CK_UE_API ULevelStreamingSubsystem : public UGameInstanceSubsystem, public FTickableGameObject
{
    GENERATED_BODY()
 
public:
    ULevelStreamingSubsystem();
    virtual void Initialize(FSubsystemCollectionBase& Collection) override;
 
public:
    UFUNCTION(BlueprintCallable, Category = "Level|Streaming")
    void RequestLevelLoad(ULevelStreamingData* ReqLevelLoadPipelineData);
 
public:
    FORCEINLINE bool IsAvailable() const
    {
        const UWorld* World = GetGameInstance()->GetWorld();
        return World && World->GetStreamingLevels().Num() > 0;
    }
 
protected:
    virtual void Tick(float DeltaTime) override;
    virtual bool IsTickable() const override;
    
    FString HandleLevelLoading(ULevelStreamingData* ReqLevelLoadPipelineData, ULevelStreaming* TargetLevel);
    bool InvalidateLevelLoadRequest(const ULevelStreamingData* ReqLevelLoadPipelineData, ULevelStreaming*& PreviousLevelStreaming) const;
 
    virtual TStatId GetStatId() const override
    {
        RETURN_QUICK_DECLARE_CYCLE_STAT(ULevelStreamingSubsystem, STATGROUP_Tickables);
    }
 
private:
    void FinalizeLevelLoadProcess(ELevelStreamingPhase Phase);
 
    // WholeEffects에서 Phase에 해당하는 이펙트를 꺼내 ChainExecutor를 시작합니다.
    void StartChain(ELevelStreamingPhase Phase);
 
 
    UFUNCTION()
    void OnLevelLoaded();
 
    UFUNCTION()
    void OnLevelShown();
 
    void StartDuringLoadPhase();
    void EvaluateDuringLoadCompletion();
 
    // 번들 비동기 로드 완료 시 OnLevelLoadedInMemory 브로드캐스트
    void NotifyLevelLoaded(ULevelRuleData* Rule) const;
 
 
public:
    UPROPERTY(EditAnywhere, Category = "Debug")
    bool bDebugMode = true;
 
    UPROPERTY(EditAnywhere)
    int32 StreamingWindowSize = 3;
 
    UPROPERTY(BlueprintAssignable, Category = "Level|Streaming")
    FOnLevelLoadCompleted OnLevelLoadCompleted;
 
    UPROPERTY(BlueprintAssignable, Category = "Level|Streaming")
    FOnLevelLoadedInMemory OnLevelLoadedInMemory;
 
    UPROPERTY(BlueprintAssignable, Category = "Level|Streaming")
    FOnPlacePlayerTheWorld OnPlacePlayerTheWorld;
 
private:
    // GC 방지용 이펙트 소유 목록 — ChainExecutor는 이 배열의 원시 포인터를 참조합니다.
    UPROPERTY(Transient)
    TArray<TObjectPtr<ULevelStreamingEffect>> AllRegisteredEffects;
 
    UPROPERTY(Transient)
    TObjectPtr<ULevelStreamingData> LevelStreamingData;
 
    UPROPERTY(Transient)
    TWeakObjectPtr<ULevelStreaming> LevelToLoad;
 
    UPROPERTY(Transient)
    TWeakObjectPtr<ULevelStreaming> LevelToUnload;
 
    UPROPERTY(Transient)
    TObjectPtr<UDataBundleRegistry> BundleRegistry;
 
    UPROPERTY(Transient)
    FLevelStreamingDeque LevelStreamingDeque;
 
    // 이펙트 체인 실행기 — 체인 진행 상태 및 Phase별 디스패치를 담당합니다.
    FEffectChainExecutor ChainExecutor;
 
private:
    bool bIsLevelLoadRequested = false;
    bool bAsyncLoading = false;
    bool bLevelLoadDone = false;
    bool bDuringLoadChainDone = false;
    bool bFakeLoadingDone = false;
 
    FTSTicker::FDelegateHandle FakeLoadingTickerHandle;
};