mirror of
https://github.com/GeWuYou/GFramework.git
synced 2026-05-07 00:39:00 +08:00
57d848546f
- 新增 notification 与 stream dispatch binding 上下文刷新回归，锁定缓存复用时仍按当次分发重新注入上下文 - 补充测试替身记录 handler 实例身份与 ArchitectureContext，覆盖重复分发场景 - 更新 cqrs-rewrite 跟踪与 trace，记录 RP-058 和 RP-059 的验证结论
33 lines
1.3 KiB
C#
33 lines
1.3 KiB
C#
using System.Collections.Generic;
|
|
using System.Runtime.CompilerServices;
|
|
using System.Threading;
|
|
using GFramework.Cqrs.Abstractions.Cqrs;
|
|
using GFramework.Cqrs.Cqrs;
|
|
|
|
namespace GFramework.Cqrs.Tests.Cqrs;
|
|
|
|
/// <summary>
|
|
/// 记录缓存 stream binding 复用场景下每次分发注入到 handler 的上下文与实例身份。
|
|
/// </summary>
|
|
internal sealed class DispatcherStreamContextRefreshHandler
|
|
: CqrsContextAwareHandlerBase,
|
|
IStreamRequestHandler<DispatcherStreamContextRefreshRequest, int>
|
|
{
|
|
private readonly int _instanceId = DispatcherStreamContextRefreshState.AllocateHandlerInstanceId();
|
|
|
|
/// <summary>
|
|
/// 记录当前 handler 实例收到的上下文，并返回稳定元素。
|
|
/// </summary>
|
|
/// <param name="request">当前流请求。</param>
|
|
/// <param name="cancellationToken">取消令牌。</param>
|
|
/// <returns>包含一个固定元素的异步流。</returns>
|
|
public async IAsyncEnumerable<int> Handle(
|
|
DispatcherStreamContextRefreshRequest request,
|
|
[EnumeratorCancellation] CancellationToken cancellationToken)
|
|
{
|
|
DispatcherStreamContextRefreshState.Record(request.DispatchId, _instanceId, Context);
|
|
yield return 11;
|
|
await ValueTask.CompletedTask.ConfigureAwait(false);
|
|
}
|
|
}
|