Skip to content

Commit

Permalink
test: Fix AsyncUpdatableRxPropTest
Browse files Browse the repository at this point in the history
  • Loading branch information
OnedgeLee committed Jun 13, 2024
1 parent 02e70ee commit a1aca87
Showing 1 changed file with 10 additions and 7 deletions.
17 changes: 10 additions & 7 deletions nekoyume/Assets/Tests/EditMode/State/AsyncUpdatableRxPropTest.cs
Original file line number Diff line number Diff line change
@@ -1,10 +1,12 @@
using System.Collections;
using System.Collections;
using System.Threading.Tasks;
using Cysharp.Threading.Tasks;
using Nekoyume.State;
using NUnit.Framework;
using UnityEngine.TestTools;
using UniRx;
using Libplanet.Common;
using System.Security.Cryptography;

namespace Tests.EditMode.State
{
Expand All @@ -31,7 +33,7 @@ public void ConstructWithDefaultValueTest(int value)
public IEnumerator UpdateAsyncTest() => UniTask.ToCoroutine(async () =>
{
var rp = new AsyncUpdatableRxProp<int>(UpdateValueAsync);
var value = await rp.UpdateAsync();
var value = await rp.UpdateAsync(new HashDigest<SHA256>());
Assert.AreEqual(1, value);
Assert.AreEqual(value, rp.Value);
});
Expand All @@ -40,9 +42,9 @@ public IEnumerator UpdateAsyncTest() => UniTask.ToCoroutine(async () =>
public IEnumerator UpdateAsObservableTest() => UniTask.ToCoroutine(async () =>
{
var rp = new AsyncUpdatableRxProp<int>(UpdateValueAsync);
var value = await rp.UpdateAsObservable().ToUniTask();
var value = await rp.UpdateAsObservable(new HashDigest<SHA256>()).ToUniTask();
Assert.AreEqual(1, value);
value = await rp.UpdateAsObservable().ToUniTask();
value = await rp.UpdateAsObservable(new HashDigest<SHA256>()).ToUniTask();
Assert.AreEqual(2, value);
});

Expand All @@ -62,7 +64,8 @@ public IEnumerator SubscribeWithUpdateOnceTest() => UniTask.ToCoroutine(async ()
}
expected++;
});
},
new HashDigest<SHA256>());
await UniTask.WaitUntil(() => done);
disposable.Dispose();
});
Expand All @@ -82,14 +85,14 @@ public IEnumerator SubscribeTest() => UniTask.ToCoroutine(async () =>
return;
}
rp.UpdateAsync().Forget();
rp.UpdateAsync(new HashDigest<SHA256>()).Forget();
expected++;
});
await UniTask.WaitUntil(() => done);
disposable.Dispose();
});

private static async Task<int> UpdateValueAsync(int previous)
private static async Task<int> UpdateValueAsync(int previous, HashDigest<SHA256> stateRootHash)
{
await UniTask.Delay(10);
return previous + 1;
Expand Down

0 comments on commit a1aca87

Please sign in to comment.