GameCult/Aetheria
Watch
9
0
Fork
You've already forked Aetheria
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use provider-native observed docking access

Browse source
This commit is contained in:
Meta Vens 2026-06-29 06:35:20 +01:00
commit d27e8ccee1
6 changed files with 24 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

19
Assets/Scripts/Gameplay/AetheriaUnityObservedDockingIndex.cs
View file

@ -9,17 +9,13 @@ using GameCult.Mesh;
public sealed class AetheriaUnityObservedDockingIndex : IDisposable
{
private readonly Func<AetheriaClient> _resolveClient;
private readonly AetheriaUnityObservedEntityIndex _observedEntityIndex;
private CultMeshReactiveDocument<AetheriaRuntimeCurrentEntityDocument> _currentEntity;
private CultMeshReactiveDocument<AetheriaRuntimeCurrentDockingDocument> _currentDocking;
private CultMeshReactiveDocument<AetheriaRuntimeStationRefitDocument> _stationRefit;
public AetheriaUnityObservedDockingIndex(
Func<AetheriaClient> resolveClient,
AetheriaUnityObservedEntityIndex observedEntityIndex)
public AetheriaUnityObservedDockingIndex(AetheriaUnityObservedEntityIndex observedEntityIndex)
{
_resolveClient = resolveClient ?? throw new ArgumentNullException(nameof(resolveClient));
_observedEntityIndex = observedEntityIndex ?? throw new ArgumentNullException(nameof(observedEntityIndex));
}
@ -208,13 +204,12 @@ public sealed class AetheriaUnityObservedDockingIndex : IDisposable
if (_currentEntity != null && _currentDocking != null && _stationRefit != null)
return;
var state = _resolveClient()?.State;
if (state == null)
return;
_currentEntity ??= state.Reactive<AetheriaRuntimeCurrentEntityDocument>();
_currentDocking ??= state.Reactive<AetheriaRuntimeCurrentDockingDocument>();
_stationRefit ??= state.Reactive<AetheriaRuntimeStationRefitDocument>();
_currentEntity ??= AetheriaUnityRuntimeClientProvider
.Reactive<AetheriaRuntimeCurrentEntityDocument>("unity-observed-docking");
_currentDocking ??= AetheriaUnityRuntimeClientProvider
.Reactive<AetheriaRuntimeCurrentDockingDocument>("unity-observed-docking");
_stationRefit ??= AetheriaUnityRuntimeClientProvider
.Reactive<AetheriaRuntimeStationRefitDocument>("unity-observed-docking");
}
public void Dispose()