diff --git a/CodeGen/Editor/EventBusILPostProcessor.cs b/CodeGen/Editor/EventBusILPostProcessor.cs
index f920898..b53c511 100644
--- a/CodeGen/Editor/EventBusILPostProcessor.cs
+++ b/CodeGen/Editor/EventBusILPostProcessor.cs
@@ -11,8 +11,8 @@ namespace ShrinkEventBus.CodeGen
{
public override ILPostProcessor GetInstance() => this;
- public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
- UnityShrinkCodeGenAdapter.ReferencesAny(compiledAssembly, "ShrinkEventBus.Runtime");
+ // ShrinkRegistryILPostProcessor owns the complete pass, including event bindings.
+ public override bool WillProcess(ICompiledAssembly compiledAssembly) => false;
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
WillProcess(compiledAssembly)
diff --git a/DotNet~/ShrinkSDK.EventBus.csproj b/DotNet~/ShrinkSDK.EventBus.csproj
index 3f61641..67c10a5 100644
--- a/DotNet~/ShrinkSDK.EventBus.csproj
+++ b/DotNet~/ShrinkSDK.EventBus.csproj
@@ -5,7 +5,7 @@
ShrinkEventBus.Runtime
ShrinkEventBus
ShrinkSDK.EventBus
- 2.1.0
+ 2.2.2
ShrinkSDK typed event bus runtime.
false
@@ -13,7 +13,7 @@
-
+
diff --git a/README.md b/README.md
index d16d261..9617ca0 100644
--- a/README.md
+++ b/README.md
@@ -182,3 +182,13 @@ ShrinkEventBusBenchmark.Run(
- Editor 诊断是可选观察层，不参与正式无诊断热路径。
架构审计与来源说明见 `Docs/JustAnyProjectArchitectureAudit.md` 和根目录 `DESIGN.md`。
+
+## 可复用能力
+
+
+Capability: 按类型发布事实和请求，支持同步、异步、优先级和可撤回订阅
+Aliases: 事件 事件未触发 消息 订阅 通知 event bus
+Limits: EventBus 不等于业务状态机或资源计量；并行派发须由业务明确选择
+Extension: IShrinkEvent、ShrinkSubscribe、BusOptions 和拥有者 Attach/Dispose
+Evidence: [EventBus](Runtime/EventBus.cs); [ShrinkSubscribeAttribute](Runtime/ShrinkEventAttributes.cs); [ShrinkGeneratedBinding](Runtime/ShrinkEventBindings.cs)
+
diff --git a/Runtime/EventBus.cs b/Runtime/EventBus.cs
index 5e611ff..caea5f3 100644
--- a/Runtime/EventBus.cs
+++ b/Runtime/EventBus.cs
@@ -143,6 +143,14 @@ namespace ShrinkEventBus
return generated.AttachGenerated(Resolver, defaultBus ?? ShrinkBusKey.Game);
}
+ public static IReadOnlyList<(Type EventType, System.Reflection.MethodInfo Handler)> CaptureBindings(IShrinkEventBus bus)
+ {
+ if (bus is ShrinkEventBusInstance instance) return instance.CaptureBindings();
+ throw new NotSupportedException("This event bus does not expose binding diagnostics.");
+ }
+
+ public static IReadOnlyList CaptureNamedBuses() => new List(Buses.Values);
+
internal static IReadOnlyList<(ShrinkBusKey Key, ShrinkBusOptions Options, int Subscribers)> Snapshot()
{
var snapshot = new List<(ShrinkBusKey, ShrinkBusOptions, int)>(Buses.Count);
diff --git a/Runtime/ShrinkEventBusCore.cs b/Runtime/ShrinkEventBusCore.cs
index af3fdb6..e004126 100644
--- a/Runtime/ShrinkEventBusCore.cs
+++ b/Runtime/ShrinkEventBusCore.cs
@@ -14,6 +14,7 @@ namespace ShrinkEventBus
internal interface IShrinkEventChannel
{
int Count { get; }
+ void CaptureBindings(List<(Type EventType, System.Reflection.MethodInfo Handler)> bindings);
bool RemoveSubscription(long subscriptionId);
void Clear();
void DetachSlot(int slot);
@@ -87,6 +88,15 @@ namespace ShrinkEventBus
private Action? _syncDispatcher;
public int Count => _snapshot.Length;
+ public void CaptureBindings(List<(Type EventType, System.Reflection.MethodInfo Handler)> bindings)
+ {
+ var snapshot = _snapshot;
+ foreach (var entry in snapshot)
+ {
+ var method = entry.SyncHandler?.Method ?? entry.AsyncHandler?.Method;
+ if (method != null) bindings.Add((typeof(TEvent), method));
+ }
+ }
public void Add(long subscriptionId, long registrationOrder, Action handler,
ShrinkSubscribeDescriptor descriptor)
diff --git a/Runtime/ShrinkEventBusInstance.cs b/Runtime/ShrinkEventBusInstance.cs
index bff0246..5465f2a 100644
--- a/Runtime/ShrinkEventBusInstance.cs
+++ b/Runtime/ShrinkEventBusInstance.cs
@@ -75,7 +75,7 @@ namespace ShrinkEventBus
[MethodImpl(MethodImplOptions.AggressiveInlining)]
public virtual ShrinkPostResult Post(in TEvent eventData) where TEvent : IShrinkEvent
{
- if (eventData is null)
+ if (!typeof(TEvent).IsValueType && eventData is null)
throw new ArgumentNullException(nameof(eventData));
if (Volatile.Read(ref _disposed) != 0)
return TraceWithoutDispatch(in eventData,
@@ -84,6 +84,11 @@ namespace ShrinkEventBus
if (_isInline || _scheduler.IsOnSchedulerThread)
return Dispatch(in eventData);
+ return PostScheduled(in eventData);
+ }
+
+ private ShrinkPostResult PostScheduled(in TEvent eventData) where TEvent : IShrinkEvent
+ {
var queuedEvent = eventData;
if (_scheduler.TryPost(() => Dispatch(in queuedEvent)))
return new ShrinkPostResult(true, false, false);
@@ -94,7 +99,7 @@ namespace ShrinkEventBus
public virtual UniTask PostAsync(TEvent eventData,
CancellationToken cancellationToken = default) where TEvent : IShrinkEvent
{
- if (eventData is null)
+ if (!typeof(TEvent).IsValueType && eventData is null)
throw new ArgumentNullException(nameof(eventData));
if (Volatile.Read(ref _disposed) != 0)
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
@@ -168,6 +173,13 @@ namespace ShrinkEventBus
return new EventSubscription(this, subscriptionId);
}
+ internal IReadOnlyList<(Type EventType, System.Reflection.MethodInfo Handler)> CaptureBindings()
+ {
+ var bindings = new List<(Type, System.Reflection.MethodInfo)>();
+ lock (_channelGate) foreach (var channel in _channels.Values) channel.CaptureBindings(bindings);
+ return bindings;
+ }
+
internal int SubscriberCount
{
get
@@ -367,7 +379,7 @@ namespace ShrinkEventBus
[MethodImpl(MethodImplOptions.AggressiveInlining)]
public override ShrinkPostResult Post(in TEvent eventData)
{
- if (eventData is null)
+ if (!typeof(TEvent).IsValueType && eventData is null)
throw new ArgumentNullException(nameof(eventData));
if (IsDisposed)
return TraceWithoutDispatch(in eventData,
@@ -378,7 +390,7 @@ namespace ShrinkEventBus
public override UniTask PostAsync(TEvent eventData,
CancellationToken cancellationToken = default)
{
- if (eventData is null)
+ if (!typeof(TEvent).IsValueType && eventData is null)
throw new ArgumentNullException(nameof(eventData));
if (IsDisposed)
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
diff --git a/package.json b/package.json
index 7c5da1e..4b7e866 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "com.cneicy.shrink-eventbus",
- "version": "2.1.0",
+ "version": "2.2.2",
"displayName": "ShrinkEventBus",
"description": "多 Bus、特性强类型注册、UniTask 调度与低分配发布的 Unity 事件总线。",
"unity": "2022.3",
@@ -10,7 +10,7 @@
"dependencies": {
"com.cysharp.unitask": "2.5.10",
"com.unity.nuget.mono-cecil": "1.11.4",
- "com.cneicy.shrink-shared-codegen": "0.1.1",
+ "com.cneicy.shrink-shared-codegen": "0.2.1",
"com.cneicy.shrink-runtime-abstractions": "0.1.0"
},
"keywords": [