From d49f191de770a5255a10f7272e888c634e9f066c Mon Sep 17 00:00:00 2001
From: Tim <nebukam@gmail.com>
Date: Thu, 17 Oct 2024 10:19:04 -0400
Subject: [PATCH] Added fetch to connect point for scoped readers

---
 .../PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp | 6 ++++++
 Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h | 1 +
 2 files changed, 7 insertions(+)

diff --git a/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp b/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp
index 5be9f0d3..fc37db4e 100644
--- a/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp
+++ b/Source/PCGExtendedToolkit/Private/Graph/PCGExConnectPoints.cpp
@@ -231,6 +231,12 @@ namespace PCGExConnectPoints
 		for (int i = 0; i < Loops.Num(); i++) { DistributedEdgesSet.Add(MakeShared<TSet<uint64>>()); }
 	}
 
+	void FProcessor::PrepareSingleLoopScopeForPoints(const uint32 StartIndex, const int32 Count)
+	{
+		TPointsProcessor<FPCGExConnectPointsContext, UPCGExConnectPointsSettings>::PrepareSingleLoopScopeForPoints(StartIndex, Count);
+		PointDataFacade->Fetch(StartIndex, Count);
+	}
+
 	void FProcessor::ProcessSinglePoint(const int32 Index, FPCGPoint& Point, const int32 LoopIdx, const int32 Count)
 	{
 		TRACE_CPUPROFILER_EVENT_SCOPE(FPCGExConnectPointsElement::ProcessSinglePoint);
diff --git a/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h b/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h
index f4892de4..cbea55a9 100644
--- a/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h
+++ b/Source/PCGExtendedToolkit/Public/Graph/PCGExConnectPoints.h
@@ -169,6 +169,7 @@ namespace PCGExConnectPoints
 		virtual bool Process(const TSharedPtr<PCGExMT::FTaskManager> InAsyncManager) override;
 		void OnPreparationComplete();
 		virtual void PrepareLoopScopesForPoints(const TArray<uint64>& Loops) override;
+		virtual void PrepareSingleLoopScopeForPoints(const uint32 StartIndex, const int32 Count) override;
 		virtual void ProcessSinglePoint(const int32 Index, FPCGPoint& Point, const int32 LoopIdx, const int32 Count) override;
 		virtual void CompleteWork() override;
 		virtual void Write() override;