diff --git a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/Runtime/GlobalMessagePipe.cs b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/Runtime/GlobalMessagePipe.cs index 2181247..2401495 100644 --- a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/Runtime/GlobalMessagePipe.cs +++ b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/Runtime/GlobalMessagePipe.cs @@ -109,6 +109,30 @@ public static IAsyncRequestAllHandler GetAsyncRequestAllHan return provider.GetRequiredService>(); } + public static IBufferedPublisher GetBufferedPublisher() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedSubscriber GetBufferedSubscriber() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedAsyncPublisher GetAsyncBufferedPublisher() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedAsyncSubscriber GetAsyncBufferedSubscriber() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + #if !UNITY_2018_3_OR_NEWER public static IDistributedPublisher GetDistributedPublisher() diff --git a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/package.json b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/package.json index 5ef8751..43153da 100644 --- a/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/package.json +++ b/src/MessagePipe.Unity/Assets/Plugins/MessagePipe/package.json @@ -2,7 +2,7 @@ "name": "com.cysharp.messagepipe", "displayName": "MessagePipe", "author": { "name": "Cysharp, Inc.", "url": "https://cysharp.co.jp/en/" }, - "version": "1.7.3", + "version": "1.7.4", "unity": "2018.4", "description": "High performance messaging pipeline.", "keywords": [ "pubsub", "event", "Scripting", "DI" ], diff --git a/src/MessagePipe/GlobalMessagePipe.cs b/src/MessagePipe/GlobalMessagePipe.cs index 72fac29..530548d 100644 --- a/src/MessagePipe/GlobalMessagePipe.cs +++ b/src/MessagePipe/GlobalMessagePipe.cs @@ -109,6 +109,30 @@ public static IAsyncRequestAllHandler GetAsyncRequestAllHan return provider.GetRequiredService>(); } + public static IBufferedPublisher GetBufferedPublisher() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedSubscriber GetBufferedSubscriber() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedAsyncPublisher GetAsyncBufferedPublisher() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + + public static IBufferedAsyncSubscriber GetAsyncBufferedSubscriber() + { + ThrowIfNotInitialized(); + return provider.GetRequiredService>(); + } + #if !UNITY_2018_3_OR_NEWER public static IDistributedPublisher GetDistributedPublisher()