-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathAdditiveSceneLoader.cs
More file actions
59 lines (52 loc) · 2.69 KB
/
AdditiveSceneLoader.cs
File metadata and controls
59 lines (52 loc) · 2.69 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
using System;
using System.Threading;
using UnityEngine;
using Cysharp.Threading.Tasks;
using VContainer;
using VContainer.Unity;
using MessagePipe;
using UnityEngine.SceneManagement;
namespace MyGame
{
// Загрузчик дополнений сцен.
// Использует из GameLifetimeScope уже загруженные ассеты.
// Так как намерение на загрузку вызывается в асинхронном режиме, то и подписываться должны на асинхронную шину.
// Через асинхронный обработчик сможем управлять временем передачи управления издателю сообщения, если он ждёт.
// CancellationToken очень помогает избегать лишних проверок на удаление объекта из "дерева" Unity.
public class AdditiveSceneLoader: IStartable, IDisposable
{
readonly GameLifetimeScope scope;
readonly IAsyncSubscriber<LoadAdditiveSceneIntention> subscriberOfLoadAdditiveSceneIntention;
IDisposable disposable;
public AdditiveSceneLoader(GameLifetimeScope scope, IAsyncSubscriber<LoadAdditiveSceneIntention> subscriberOfLoadAdditiveSceneIntention)
{
this.scope = scope;
this.subscriberOfLoadAdditiveSceneIntention = subscriberOfLoadAdditiveSceneIntention;
}
async UniTask OnLoadAdditiveSceneIntention(LoadAdditiveSceneIntention e, CancellationToken cancellationToken)
{
using (LifetimeScope.Enqueue(innerBuilder =>
{
// См. GameLifetimeScope с такой же строкой
// innerBuilder.RegisterMessageBroker<int>(scope.CommonOptionsOfMessagePipe);
innerBuilder.RegisterInstance(scope.CubeAnimationParameters);
innerBuilder.RegisterInstance(scope.CubePrefabs);
}))
{
await SceneManager.LoadSceneAsync(e.name, LoadSceneMode.Additive).WithCancellation(cancellationToken);
}
await UniTask.Delay(3000, DelayType.Realtime, PlayerLoopTiming.Update, cancellationToken, true).SuppressCancellationThrow();
}
void IStartable.Start()
{
var d = DisposableBag.CreateBuilder();
subscriberOfLoadAdditiveSceneIntention.Subscribe(OnLoadAdditiveSceneIntention).AddTo(d);
disposable = d.Build();
}
void IDisposable.Dispose()
{
disposable.Dispose();
Debug.Log( String.Format("{0} Disposed!", this.GetType().Name));
}
}
}