Compare commits
10
Commits
8aa4c79604
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
a92c9d2cea
|
||
|
|
c44a7e6dda
|
||
|
|
f9c249a4d1
|
||
|
|
4ec3011320
|
||
|
|
2b8e568efa
|
||
|
|
3265cbe9b8
|
||
|
|
8adc334bfa
|
||
|
|
c5e29cb313
|
||
|
|
3bcfa56fae
|
||
|
|
64ce75a341
|
@@ -0,0 +1,123 @@
|
|||||||
|
name: Publish NuGet packages
|
||||||
|
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
tags:
|
||||||
|
- 'v*'
|
||||||
|
workflow_dispatch:
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
publish:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
permissions:
|
||||||
|
contents: read
|
||||||
|
packages: write
|
||||||
|
env:
|
||||||
|
NUGET_AUTH_TOKEN: ${{ secrets.SHRINKSDK_PACKAGE_TOKEN }}
|
||||||
|
DOTNET_SYSTEM_GLOBALIZATION_INVARIANT: '1'
|
||||||
|
DOTNET_CLI_TELEMETRY_OPTOUT: '1'
|
||||||
|
LD_LIBRARY_PATH: /opt/dotnet-libs/usr/lib/x86_64-linux-gnu
|
||||||
|
SSL_CERT_FILE: /opt/ca-certificates.crt
|
||||||
|
steps:
|
||||||
|
- name: Fetch exact tagged source
|
||||||
|
env:
|
||||||
|
GITEA_REF: ${{ gitea.ref }}
|
||||||
|
GITEA_REPOSITORY: ${{ gitea.repository }}
|
||||||
|
shell: bash
|
||||||
|
run: |
|
||||||
|
set -euo pipefail
|
||||||
|
tag="${GITEA_REF#refs/tags/}"
|
||||||
|
case "$tag" in
|
||||||
|
v[0-9]*) ;;
|
||||||
|
*) echo "Expected a version tag ref, got: $GITEA_REF" >&2; exit 1 ;;
|
||||||
|
esac
|
||||||
|
export SHRINKSDK_ARCHIVE_URL="https://git.crash.work/${GITEA_REPOSITORY}/archive/${tag}.tar.gz"
|
||||||
|
node --input-type=module <<'NODE'
|
||||||
|
import { writeFile } from 'node:fs/promises';
|
||||||
|
|
||||||
|
const response = await fetch(process.env.SHRINKSDK_ARCHIVE_URL);
|
||||||
|
if (!response.ok) {
|
||||||
|
throw new Error(`Release archive download failed: ${response.status} ${response.statusText}`);
|
||||||
|
}
|
||||||
|
await writeFile('release.tar.gz', new Uint8Array(await response.arrayBuffer()));
|
||||||
|
NODE
|
||||||
|
mkdir release
|
||||||
|
tar -xzf release.tar.gz --strip-components=1 -C release
|
||||||
|
rm -f release.tar.gz
|
||||||
|
printf '%s' "$tag" > release/.shrink-sdk-release-tag
|
||||||
|
|
||||||
|
- name: Install .NET 8 SDK
|
||||||
|
shell: bash
|
||||||
|
run: |
|
||||||
|
set -euo pipefail
|
||||||
|
node --input-type=module <<'NODE'
|
||||||
|
import { writeFile } from 'node:fs/promises';
|
||||||
|
import { rootCertificates } from 'node:tls';
|
||||||
|
|
||||||
|
await writeFile('/opt/ca-certificates.crt', rootCertificates.join('\n'));
|
||||||
|
|
||||||
|
const metadataResponse = await fetch('https://dotnetcli.blob.core.windows.net/dotnet/release-metadata/8.0/releases.json');
|
||||||
|
if (!metadataResponse.ok) throw new Error(`Release metadata download failed: ${metadataResponse.status}`);
|
||||||
|
const metadata = await metadataResponse.json();
|
||||||
|
const sdkVersion = metadata['latest-sdk'];
|
||||||
|
const release = metadata.releases.find(item => item.sdk?.version === sdkVersion);
|
||||||
|
const file = release?.sdk?.files?.find(item => item.rid === 'linux-x64' && item.name.endsWith('.tar.gz'));
|
||||||
|
if (!file) throw new Error(`Linux x64 SDK archive not found for ${sdkVersion}`);
|
||||||
|
const archiveResponse = await fetch(file.url);
|
||||||
|
if (!archiveResponse.ok) throw new Error(`SDK download failed: ${archiveResponse.status}`);
|
||||||
|
await writeFile('/tmp/dotnet-sdk.tar.gz', new Uint8Array(await archiveResponse.arrayBuffer()));
|
||||||
|
|
||||||
|
const poolUrl = 'https://deb.debian.org/debian-security/pool/updates/main/o/openssl/';
|
||||||
|
const poolResponse = await fetch(poolUrl);
|
||||||
|
if (!poolResponse.ok) throw new Error(`OpenSSL package index download failed: ${poolResponse.status}`);
|
||||||
|
const poolIndex = await poolResponse.text();
|
||||||
|
const packages = [...poolIndex.matchAll(/href="(libssl3_[^"]+_amd64\.deb)"/g)].map(match => match[1]).sort();
|
||||||
|
const packageName = packages.at(-1);
|
||||||
|
if (!packageName) throw new Error('Debian libssl3 package was not found');
|
||||||
|
const packageResponse = await fetch(poolUrl + packageName);
|
||||||
|
if (!packageResponse.ok) throw new Error(`OpenSSL package download failed: ${packageResponse.status}`);
|
||||||
|
await writeFile('/tmp/libssl3.deb', new Uint8Array(await packageResponse.arrayBuffer()));
|
||||||
|
NODE
|
||||||
|
mkdir -p /opt/dotnet
|
||||||
|
tar -xzf /tmp/dotnet-sdk.tar.gz -C /opt/dotnet
|
||||||
|
mkdir -p /opt/dotnet-libs
|
||||||
|
dpkg-deb -x /tmp/libssl3.deb /opt/dotnet-libs
|
||||||
|
rm -f /tmp/dotnet-sdk.tar.gz
|
||||||
|
rm -f /tmp/libssl3.deb
|
||||||
|
/opt/dotnet/dotnet --info
|
||||||
|
|
||||||
|
- name: Validate, pack and publish
|
||||||
|
shell: bash
|
||||||
|
run: |
|
||||||
|
set -euo pipefail
|
||||||
|
: "${NUGET_AUTH_TOKEN:?SHRINKSDK_PACKAGE_TOKEN is required}"
|
||||||
|
export PATH="/opt/dotnet:$PATH"
|
||||||
|
cd release
|
||||||
|
tag="$(cat .shrink-sdk-release-tag)"
|
||||||
|
projects=()
|
||||||
|
if [[ -d DotNet~ ]]; then
|
||||||
|
while IFS= read -r -d '' project; do projects+=("$project"); done < <(find DotNet~ -type f -name '*.csproj' -print0)
|
||||||
|
fi
|
||||||
|
if [[ -d Godot~ ]]; then
|
||||||
|
while IFS= read -r -d '' project; do projects+=("$project"); done < <(find Godot~ -type f -name '*.csproj' -print0)
|
||||||
|
fi
|
||||||
|
if [[ "${#projects[@]}" -eq 0 ]]; then
|
||||||
|
while IFS= read -r -d '' project; do projects+=("$project"); done < <(find . -maxdepth 1 -type f -name '*.csproj' -print0)
|
||||||
|
fi
|
||||||
|
test "${#projects[@]}" -gt 0
|
||||||
|
if [[ -f package.json ]]; then
|
||||||
|
version="$(node -p "require('./package.json').version")"
|
||||||
|
else
|
||||||
|
version="$(dotnet msbuild "${projects[0]}" -getProperty:Version -nologo)"
|
||||||
|
fi
|
||||||
|
test "$tag" = "v$version"
|
||||||
|
mkdir -p packages
|
||||||
|
for project in "${projects[@]}"; do
|
||||||
|
dotnet restore "$project" --configfile NuGet.Config
|
||||||
|
dotnet pack "$project" --configuration Release --no-restore --output "$PWD/packages" --include-symbols --include-source
|
||||||
|
done
|
||||||
|
find packages -maxdepth 1 -name '*.nupkg' -type f | grep -q .
|
||||||
|
dotnet nuget push 'packages/*.nupkg' --api-key "$NUGET_AUTH_TOKEN" --source https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json --skip-duplicate
|
||||||
|
if compgen -G 'packages/*.snupkg' > /dev/null; then
|
||||||
|
dotnet nuget push 'packages/*.snupkg' --api-key "$NUGET_AUTH_TOKEN" --source https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json --skip-duplicate
|
||||||
|
fi
|
||||||
+12
@@ -30,6 +30,16 @@
|
|||||||
/[Aa]ssets/Plugins/Editor/JetBrains*
|
/[Aa]ssets/Plugins/Editor/JetBrains*
|
||||||
# Jetbrains Rider personal-layer settings
|
# Jetbrains Rider personal-layer settings
|
||||||
*.DotSettings.user
|
*.DotSettings.user
|
||||||
|
!DotNet~/*.csproj
|
||||||
|
!DotNet~/**/*.csproj
|
||||||
|
/DotNet~/**/[Bb]in/
|
||||||
|
/DotNet~/**/[Oo]bj/
|
||||||
|
/Godot~/**/[Bb]in/
|
||||||
|
/Godot~/**/[Oo]bj/
|
||||||
|
/artifacts/
|
||||||
|
/packages/
|
||||||
|
!DotNet~/**/*.csproj
|
||||||
|
!Godot~/**/*.csproj
|
||||||
|
|
||||||
# Visual Studio cache directory
|
# Visual Studio cache directory
|
||||||
.vs/
|
.vs/
|
||||||
@@ -108,3 +118,5 @@ InitTestScene*.unity*
|
|||||||
/Tools~/**/[Oo]bj/
|
/Tools~/**/[Oo]bj/
|
||||||
*.user
|
*.user
|
||||||
*.DotSettings.user
|
*.DotSettings.user
|
||||||
|
!DotNet~/*.csproj
|
||||||
|
!DotNet~/**/*.csproj
|
||||||
|
|||||||
@@ -6,3 +6,9 @@ Tools~/
|
|||||||
*.sln
|
*.sln
|
||||||
*.user
|
*.user
|
||||||
*.DotSettings.user
|
*.DotSettings.user
|
||||||
|
DotNet~/
|
||||||
|
Godot~/
|
||||||
|
NuGet.Config
|
||||||
|
Directory.Build.props
|
||||||
|
NuGet.Config.meta
|
||||||
|
Directory.Build.props.meta
|
||||||
|
|||||||
@@ -11,8 +11,8 @@ namespace ShrinkEventBus.CodeGen
|
|||||||
{
|
{
|
||||||
public override ILPostProcessor GetInstance() => this;
|
public override ILPostProcessor GetInstance() => this;
|
||||||
|
|
||||||
public override bool WillProcess(ICompiledAssembly compiledAssembly) =>
|
// ShrinkRegistryILPostProcessor owns the complete pass, including event bindings.
|
||||||
UnityShrinkCodeGenAdapter.ReferencesAny(compiledAssembly, "ShrinkEventBus.Runtime");
|
public override bool WillProcess(ICompiledAssembly compiledAssembly) => false;
|
||||||
|
|
||||||
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
|
public override ILPostProcessResult Process(ICompiledAssembly compiledAssembly) =>
|
||||||
WillProcess(compiledAssembly)
|
WillProcess(compiledAssembly)
|
||||||
|
|||||||
@@ -0,0 +1,13 @@
|
|||||||
|
<Project>
|
||||||
|
<PropertyGroup>
|
||||||
|
<LangVersion>latest</LangVersion>
|
||||||
|
<Nullable>enable</Nullable>
|
||||||
|
<Deterministic>true</Deterministic>
|
||||||
|
<ContinuousIntegrationBuild>true</ContinuousIntegrationBuild>
|
||||||
|
<Authors>ShrinkSDK</Authors>
|
||||||
|
<Company>ShrinkSDK</Company>
|
||||||
|
<RepositoryUrl>https://git.crash.work/ShrinkSDK</RepositoryUrl>
|
||||||
|
<IncludeSymbols>true</IncludeSymbols>
|
||||||
|
<SymbolPackageFormat>snupkg</SymbolPackageFormat>
|
||||||
|
</PropertyGroup>
|
||||||
|
</Project>
|
||||||
@@ -0,0 +1,7 @@
|
|||||||
|
fileFormatVersion: 2
|
||||||
|
guid: bb9607b086e27c14c9be7469aac61d0d
|
||||||
|
DefaultImporter:
|
||||||
|
externalObjects: {}
|
||||||
|
userData:
|
||||||
|
assetBundleName:
|
||||||
|
assetBundleVariant:
|
||||||
@@ -0,0 +1,19 @@
|
|||||||
|
<Project Sdk="Microsoft.NET.Sdk">
|
||||||
|
<PropertyGroup>
|
||||||
|
<TargetFramework>netstandard2.1</TargetFramework>
|
||||||
|
<EnableDefaultCompileItems>false</EnableDefaultCompileItems>
|
||||||
|
<AssemblyName>ShrinkEventBus.Runtime</AssemblyName>
|
||||||
|
<RootNamespace>ShrinkEventBus</RootNamespace>
|
||||||
|
<PackageId>ShrinkSDK.EventBus</PackageId>
|
||||||
|
<Version>2.2.2</Version>
|
||||||
|
<Description>ShrinkSDK typed event bus runtime.</Description>
|
||||||
|
<ShrinkCodeGenEnabled>false</ShrinkCodeGenEnabled>
|
||||||
|
</PropertyGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<Compile Include="..\Runtime\**\*.cs"
|
||||||
|
Exclude="..\Runtime\ShrinkMonoEventScope.cs" />
|
||||||
|
<PackageReference Include="UniTask" Version="2.5.10" />
|
||||||
|
<PackageReference Include="ShrinkSDK.CodeGen" Version="0.2.0" PrivateAssets="compile;runtime;contentfiles;native" />
|
||||||
|
<PackageReference Include="ShrinkSDK.Runtime.Abstractions" Version="0.1.0" />
|
||||||
|
</ItemGroup>
|
||||||
|
</Project>
|
||||||
@@ -0,0 +1,8 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<configuration>
|
||||||
|
<packageSources>
|
||||||
|
<clear />
|
||||||
|
<add key="ShrinkSDK" value="https://git.crash.work/api/packages/ShrinkSDK/nuget/index.json" />
|
||||||
|
<add key="nuget.org" value="https://api.nuget.org/v3/index.json" protocolVersion="3" />
|
||||||
|
</packageSources>
|
||||||
|
</configuration>
|
||||||
@@ -0,0 +1,32 @@
|
|||||||
|
fileFormatVersion: 2
|
||||||
|
guid: cc42bc8ffa8649949aa6d63f9a225d27
|
||||||
|
PluginImporter:
|
||||||
|
externalObjects: {}
|
||||||
|
serializedVersion: 2
|
||||||
|
iconMap: {}
|
||||||
|
executionOrder: {}
|
||||||
|
defineConstraints: []
|
||||||
|
isPreloaded: 0
|
||||||
|
isOverridable: 0
|
||||||
|
isExplicitlyReferenced: 0
|
||||||
|
validateReferences: 1
|
||||||
|
platformData:
|
||||||
|
- first:
|
||||||
|
Any:
|
||||||
|
second:
|
||||||
|
enabled: 0
|
||||||
|
settings: {}
|
||||||
|
- first:
|
||||||
|
Editor: Editor
|
||||||
|
second:
|
||||||
|
enabled: 0
|
||||||
|
settings:
|
||||||
|
DefaultValueInitialized: true
|
||||||
|
- first:
|
||||||
|
Windows Store Apps: WindowsStoreApps
|
||||||
|
second:
|
||||||
|
enabled: 1
|
||||||
|
settings: {}
|
||||||
|
userData:
|
||||||
|
assetBundleName:
|
||||||
|
assetBundleVariant:
|
||||||
@@ -2,6 +2,8 @@
|
|||||||
|
|
||||||
ShrinkEventBus 2.0 是面向 Unity、普通 C# 宿主和 Entities/Burst 生产端的统一事件总线。运行时只有一种事件模型、一个订阅入口和一组发布 API;不同 Bus 只表达生命周期、所有权与调度策略。
|
ShrinkEventBus 2.0 是面向 Unity、普通 C# 宿主和 Entities/Burst 生产端的统一事件总线。运行时只有一种事件模型、一个订阅入口和一组发布 API;不同 Bus 只表达生命周期、所有权与调度策略。
|
||||||
|
|
||||||
|
Godot 和普通 .NET 项目安装 `ShrinkSDK.EventBus`;可打包源码位于 `DotNet~`,订阅注册由 `ShrinkSDK.CodeGen` 在构建时织入。
|
||||||
|
|
||||||
## 核心契约
|
## 核心契约
|
||||||
|
|
||||||
```csharp
|
```csharp
|
||||||
@@ -180,3 +182,13 @@ ShrinkEventBusBenchmark.Run(
|
|||||||
- Editor 诊断是可选观察层,不参与正式无诊断热路径。
|
- Editor 诊断是可选观察层,不参与正式无诊断热路径。
|
||||||
|
|
||||||
架构审计与来源说明见 `Docs/JustAnyProjectArchitectureAudit.md` 和根目录 `DESIGN.md`。
|
架构审计与来源说明见 `Docs/JustAnyProjectArchitectureAudit.md` 和根目录 `DESIGN.md`。
|
||||||
|
|
||||||
|
## 可复用能力
|
||||||
|
|
||||||
|
<!-- shrink:capabilities -->
|
||||||
|
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)
|
||||||
|
<!-- /shrink:capabilities -->
|
||||||
|
|||||||
@@ -143,6 +143,14 @@ namespace ShrinkEventBus
|
|||||||
return generated.AttachGenerated(Resolver, defaultBus ?? ShrinkBusKey.Game);
|
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<IShrinkEventBus> CaptureNamedBuses() => new List<IShrinkEventBus>(Buses.Values);
|
||||||
|
|
||||||
internal static IReadOnlyList<(ShrinkBusKey Key, ShrinkBusOptions Options, int Subscribers)> Snapshot()
|
internal static IReadOnlyList<(ShrinkBusKey Key, ShrinkBusOptions Options, int Subscribers)> Snapshot()
|
||||||
{
|
{
|
||||||
var snapshot = new List<(ShrinkBusKey, ShrinkBusOptions, int)>(Buses.Count);
|
var snapshot = new List<(ShrinkBusKey, ShrinkBusOptions, int)>(Buses.Count);
|
||||||
|
|||||||
@@ -14,6 +14,7 @@ namespace ShrinkEventBus
|
|||||||
internal interface IShrinkEventChannel
|
internal interface IShrinkEventChannel
|
||||||
{
|
{
|
||||||
int Count { get; }
|
int Count { get; }
|
||||||
|
void CaptureBindings(List<(Type EventType, System.Reflection.MethodInfo Handler)> bindings);
|
||||||
bool RemoveSubscription(long subscriptionId);
|
bool RemoveSubscription(long subscriptionId);
|
||||||
void Clear();
|
void Clear();
|
||||||
void DetachSlot(int slot);
|
void DetachSlot(int slot);
|
||||||
@@ -87,6 +88,15 @@ namespace ShrinkEventBus
|
|||||||
private Action<TEvent>? _syncDispatcher;
|
private Action<TEvent>? _syncDispatcher;
|
||||||
|
|
||||||
public int Count => _snapshot.Length;
|
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<TEvent> handler,
|
public void Add(long subscriptionId, long registrationOrder, Action<TEvent> handler,
|
||||||
ShrinkSubscribeDescriptor descriptor)
|
ShrinkSubscribeDescriptor descriptor)
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ namespace ShrinkEventBus
|
|||||||
[MethodImpl(MethodImplOptions.AggressiveInlining)]
|
[MethodImpl(MethodImplOptions.AggressiveInlining)]
|
||||||
public virtual ShrinkPostResult Post<TEvent>(in TEvent eventData) where TEvent : IShrinkEvent
|
public virtual ShrinkPostResult Post<TEvent>(in TEvent eventData) where TEvent : IShrinkEvent
|
||||||
{
|
{
|
||||||
if (eventData is null)
|
if (!typeof(TEvent).IsValueType && eventData is null)
|
||||||
throw new ArgumentNullException(nameof(eventData));
|
throw new ArgumentNullException(nameof(eventData));
|
||||||
if (Volatile.Read(ref _disposed) != 0)
|
if (Volatile.Read(ref _disposed) != 0)
|
||||||
return TraceWithoutDispatch(in eventData,
|
return TraceWithoutDispatch(in eventData,
|
||||||
@@ -84,6 +84,11 @@ namespace ShrinkEventBus
|
|||||||
if (_isInline || _scheduler.IsOnSchedulerThread)
|
if (_isInline || _scheduler.IsOnSchedulerThread)
|
||||||
return Dispatch(in eventData);
|
return Dispatch(in eventData);
|
||||||
|
|
||||||
|
return PostScheduled(in eventData);
|
||||||
|
}
|
||||||
|
|
||||||
|
private ShrinkPostResult PostScheduled<TEvent>(in TEvent eventData) where TEvent : IShrinkEvent
|
||||||
|
{
|
||||||
var queuedEvent = eventData;
|
var queuedEvent = eventData;
|
||||||
if (_scheduler.TryPost(() => Dispatch(in queuedEvent)))
|
if (_scheduler.TryPost(() => Dispatch(in queuedEvent)))
|
||||||
return new ShrinkPostResult(true, false, false);
|
return new ShrinkPostResult(true, false, false);
|
||||||
@@ -94,7 +99,7 @@ namespace ShrinkEventBus
|
|||||||
public virtual UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
|
public virtual UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
|
||||||
CancellationToken cancellationToken = default) where TEvent : IShrinkEvent
|
CancellationToken cancellationToken = default) where TEvent : IShrinkEvent
|
||||||
{
|
{
|
||||||
if (eventData is null)
|
if (!typeof(TEvent).IsValueType && eventData is null)
|
||||||
throw new ArgumentNullException(nameof(eventData));
|
throw new ArgumentNullException(nameof(eventData));
|
||||||
if (Volatile.Read(ref _disposed) != 0)
|
if (Volatile.Read(ref _disposed) != 0)
|
||||||
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
|
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
|
||||||
@@ -168,6 +173,13 @@ namespace ShrinkEventBus
|
|||||||
return new EventSubscription(this, subscriptionId);
|
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
|
internal int SubscriberCount
|
||||||
{
|
{
|
||||||
get
|
get
|
||||||
@@ -367,7 +379,7 @@ namespace ShrinkEventBus
|
|||||||
[MethodImpl(MethodImplOptions.AggressiveInlining)]
|
[MethodImpl(MethodImplOptions.AggressiveInlining)]
|
||||||
public override ShrinkPostResult Post<TEvent>(in TEvent eventData)
|
public override ShrinkPostResult Post<TEvent>(in TEvent eventData)
|
||||||
{
|
{
|
||||||
if (eventData is null)
|
if (!typeof(TEvent).IsValueType && eventData is null)
|
||||||
throw new ArgumentNullException(nameof(eventData));
|
throw new ArgumentNullException(nameof(eventData));
|
||||||
if (IsDisposed)
|
if (IsDisposed)
|
||||||
return TraceWithoutDispatch(in eventData,
|
return TraceWithoutDispatch(in eventData,
|
||||||
@@ -378,7 +390,7 @@ namespace ShrinkEventBus
|
|||||||
public override UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
|
public override UniTask<ShrinkPostResult> PostAsync<TEvent>(TEvent eventData,
|
||||||
CancellationToken cancellationToken = default)
|
CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
if (eventData is null)
|
if (!typeof(TEvent).IsValueType && eventData is null)
|
||||||
throw new ArgumentNullException(nameof(eventData));
|
throw new ArgumentNullException(nameof(eventData));
|
||||||
if (IsDisposed)
|
if (IsDisposed)
|
||||||
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
|
return UniTask.FromResult(TraceWithoutDispatch(in eventData,
|
||||||
|
|||||||
+2
-2
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "com.cneicy.shrink-eventbus",
|
"name": "com.cneicy.shrink-eventbus",
|
||||||
"version": "2.1.0",
|
"version": "2.2.2",
|
||||||
"displayName": "ShrinkEventBus",
|
"displayName": "ShrinkEventBus",
|
||||||
"description": "多 Bus、特性强类型注册、UniTask 调度与低分配发布的 Unity 事件总线。",
|
"description": "多 Bus、特性强类型注册、UniTask 调度与低分配发布的 Unity 事件总线。",
|
||||||
"unity": "2022.3",
|
"unity": "2022.3",
|
||||||
@@ -10,7 +10,7 @@
|
|||||||
"dependencies": {
|
"dependencies": {
|
||||||
"com.cysharp.unitask": "2.5.10",
|
"com.cysharp.unitask": "2.5.10",
|
||||||
"com.unity.nuget.mono-cecil": "1.11.4",
|
"com.unity.nuget.mono-cecil": "1.11.4",
|
||||||
"com.cneicy.shrink-shared-codegen": "0.1.0",
|
"com.cneicy.shrink-shared-codegen": "0.2.1",
|
||||||
"com.cneicy.shrink-runtime-abstractions": "0.1.0"
|
"com.cneicy.shrink-runtime-abstractions": "0.1.0"
|
||||||
},
|
},
|
||||||
"keywords": [
|
"keywords": [
|
||||||
|
|||||||
Reference in New Issue
Block a user