From 08e8f8b3d31833dc87816f268c7511dd087cfcde Mon Sep 17 00:00:00 2001
From: George Ananchenko <agoshezh+github@gmail.com>
Date: Mon, 30 May 2022 23:02:55 +0300
Subject: [PATCH 1/3] added Buffered overloads of GetSubscriber, GetPublisher
 to GlobalMessagePipe

---
 src/MessagePipe/GlobalMessagePipe.cs | 24 ++++++++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/src/MessagePipe/GlobalMessagePipe.cs b/src/MessagePipe/GlobalMessagePipe.cs
index 72fac29..e2db8f7 100644
--- a/src/MessagePipe/GlobalMessagePipe.cs
+++ b/src/MessagePipe/GlobalMessagePipe.cs
@@ -109,6 +109,30 @@ public static IAsyncRequestAllHandler<TRequest, TResponse> GetAsyncRequestAllHan
             return provider.GetRequiredService<IAsyncRequestAllHandler<TRequest, TResponse>>();
         }
 
+        public static IBufferedPublisher<TMessage> GetPublisher<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedPublisher<TMessage>>();
+        }
+
+        public static IBufferedSubscriber<TMessage> GetSubscriber<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedSubscriber<TMessage>>();
+        }
+
+        public static IBufferedAsyncPublisher<TMessage> GetPublisher<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedAsyncPublisher<TMessage>>();
+        }
+
+        public static IBufferedAsyncSubscriber<TMessage> GetSubscriber<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedAsyncSubscriber<TMessage>>();
+        }
+
 #if !UNITY_2018_3_OR_NEWER
 
         public static IDistributedPublisher<TKey, TMessage> GetDistributedPublisher<TKey, TMessage>()

From a65b7c18a289218949955dd23f96d90ca322b8a7 Mon Sep 17 00:00:00 2001
From: George Ananchenko <agoshezh+github@gmail.com>
Date: Mon, 30 May 2022 23:11:17 +0300
Subject: [PATCH 2/3] fix

---
 src/MessagePipe/GlobalMessagePipe.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/MessagePipe/GlobalMessagePipe.cs b/src/MessagePipe/GlobalMessagePipe.cs
index e2db8f7..530548d 100644
--- a/src/MessagePipe/GlobalMessagePipe.cs
+++ b/src/MessagePipe/GlobalMessagePipe.cs
@@ -109,25 +109,25 @@ public static IAsyncRequestAllHandler<TRequest, TResponse> GetAsyncRequestAllHan
             return provider.GetRequiredService<IAsyncRequestAllHandler<TRequest, TResponse>>();
         }
 
-        public static IBufferedPublisher<TMessage> GetPublisher<TMessage>()
+        public static IBufferedPublisher<TMessage> GetBufferedPublisher<TMessage>()
         {
             ThrowIfNotInitialized();
             return provider.GetRequiredService<IBufferedPublisher<TMessage>>();
         }
 
-        public static IBufferedSubscriber<TMessage> GetSubscriber<TMessage>()
+        public static IBufferedSubscriber<TMessage> GetBufferedSubscriber<TMessage>()
         {
             ThrowIfNotInitialized();
             return provider.GetRequiredService<IBufferedSubscriber<TMessage>>();
         }
 
-        public static IBufferedAsyncPublisher<TMessage> GetPublisher<TMessage>()
+        public static IBufferedAsyncPublisher<TMessage> GetAsyncBufferedPublisher<TMessage>()
         {
             ThrowIfNotInitialized();
             return provider.GetRequiredService<IBufferedAsyncPublisher<TMessage>>();
         }
 
-        public static IBufferedAsyncSubscriber<TMessage> GetSubscriber<TMessage>()
+        public static IBufferedAsyncSubscriber<TMessage> GetAsyncBufferedSubscriber<TMessage>()
         {
             ThrowIfNotInitialized();
             return provider.GetRequiredService<IBufferedAsyncSubscriber<TMessage>>();

From aaf9db84f62834a05f0a8dd228d2d57e692ead49 Mon Sep 17 00:00:00 2001
From: George Ananchenko <agoshezh+github@gmail.com>
Date: Mon, 30 May 2022 23:18:50 +0300
Subject: [PATCH 3/3] unity updated

---
 .../MessagePipe/Runtime/GlobalMessagePipe.cs  | 24 +++++++++++++++++++
 .../Assets/Plugins/MessagePipe/package.json   |  2 +-
 2 files changed, 25 insertions(+), 1 deletion(-)

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<TRequest, TResponse> GetAsyncRequestAllHan
             return provider.GetRequiredService<IAsyncRequestAllHandler<TRequest, TResponse>>();
         }
 
+        public static IBufferedPublisher<TMessage> GetBufferedPublisher<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedPublisher<TMessage>>();
+        }
+
+        public static IBufferedSubscriber<TMessage> GetBufferedSubscriber<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedSubscriber<TMessage>>();
+        }
+
+        public static IBufferedAsyncPublisher<TMessage> GetAsyncBufferedPublisher<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedAsyncPublisher<TMessage>>();
+        }
+
+        public static IBufferedAsyncSubscriber<TMessage> GetAsyncBufferedSubscriber<TMessage>()
+        {
+            ThrowIfNotInitialized();
+            return provider.GetRequiredService<IBufferedAsyncSubscriber<TMessage>>();
+        }
+
 #if !UNITY_2018_3_OR_NEWER
 
         public static IDistributedPublisher<TKey, TMessage> GetDistributedPublisher<TKey, TMessage>()
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" ],