EE Transport Layer Fix (#114)

* Fixed an issue where repeated sub/unsub requests with EE enabled would stop working after a while.

Author: jakub-grzesiowski

.pubnub.yml

@@ -1,6 +1,11 @@
 --- 
-version: v8.1.0
+version: v8.1.1
 changelog:
+  - date: 2025-02-25
+    version: v8.1.1
+    changes:
+      - type: bug
+        text: "Fixed an issue where repeated sub/unsub requests with EE enabled would stop working after a while."
   - date: 2025-02-04
     version: v8.1.0
     changes:
@@ -755,7 +760,7 @@ sdks:
             distribution-type: package
             distribution-repository: git release
             package-name: PubNub.unitypackage
-            location: https://github.com/pubnub/unity/releases/download/v8.1.0/PubNub.unitypackage
+            location: https://github.com/pubnub/unity/releases/download/v8.1.1/PubNub.unitypackage
             requires:
               -
                 name: "UnityEditor"
@@ -922,7 +927,7 @@ sdks:
             distribution-type: package
             distribution-repository: git release
             package-name: PubNub.unitypackage
-            location: https://github.com/pubnub/unity/releases/download/v8.1.0/PubNub.unitypackage
+            location: https://github.com/pubnub/unity/releases/download/v8.1.1/PubNub.unitypackage
             requires:
               -
                 name: "UnityEditor"

PubNubUnity/Assets/PubNub/Runtime/Plugins/PubnubApiUnity.dll

@@ -5,7 +5,7 @@ namespace PubnubApi.Unity
 {
     public class UnityPNSDKSource : IPNSDKSource {
 
-	    private const string build = "8.1.0";
+	    private const string build = "8.1.1";
 
 	    public string GetPNSDK() {
 			#if(UNITY_IOS)

PubNubUnity/Assets/PubNub/Runtime/Util/UnityPNSDKSource.cs

@@ -41,7 +41,7 @@ public async Task<TransportResponse> DeleteRequest(TransportRequest transportReq
 				var deleteRequest = UnityWebRequest.Delete(transportRequest.RequestUrl);
 				PrepareUnityRequest(deleteRequest, transportRequest);
 				var taskCompletionSource = new TaskCompletionSource<TransportResponse>();
-				transportRequest.CancellationToken.Register(() => {
+				transportRequest.CancellationTokenSource.Token.Register(() => {
 					deleteRequest.Abort();
 					taskCompletionSource.TrySetCanceled();
 				});
@@ -65,7 +65,7 @@ public async Task<TransportResponse> GetRequest(TransportRequest transportReques
 				var getRequest = UnityWebRequest.Get(transportRequest.RequestUrl);
 				PrepareUnityRequest(getRequest, transportRequest);
 				var taskCompletionSource = new TaskCompletionSource<TransportResponse>();
-				transportRequest.CancellationToken.Register(() => {
+				transportRequest.CancellationTokenSource.Token.Register(() => {
 					getRequest.Abort();
 					taskCompletionSource.TrySetCanceled();
 				});
@@ -96,7 +96,7 @@ public async Task<TransportResponse> PostRequest(TransportRequest transportReque
 				var postRequest = UnityWebRequest.Post(transportRequest.RequestUrl, formData);
 				PrepareUnityRequest(postRequest, transportRequest);
 				var taskCompletionSource = new TaskCompletionSource<TransportResponse>();
-				transportRequest.CancellationToken.Register(() => {
+				transportRequest.CancellationTokenSource.Token.Register(() => {
 					postRequest.Abort();
 					taskCompletionSource.TrySetCanceled();
 				});
@@ -129,7 +129,7 @@ public async Task<TransportResponse> PatchRequest(TransportRequest transportRequ
 
 				PrepareUnityRequest(patchRequest, transportRequest);
 				var taskCompletionSource = new TaskCompletionSource<TransportResponse>();
-				transportRequest.CancellationToken.Register(() => {
+				transportRequest.CancellationTokenSource.Token.Register(() => {
 					patchRequest.Abort();
 					taskCompletionSource.TrySetCanceled();
 				});
@@ -162,7 +162,7 @@ public async Task<TransportResponse> PutRequest(TransportRequest transportReques
 
 				PrepareUnityRequest(putRequest, transportRequest);
 				var taskCompletionSource = new TaskCompletionSource<TransportResponse>();
-				transportRequest.CancellationToken.Register(() => {
+				transportRequest.CancellationTokenSource.Token.Register(() => {
 					putRequest.Abort();
 					taskCompletionSource.TrySetCanceled();
 				});

PubNubUnity/Assets/PubNub/Runtime/Util/UnityWebGLHttpClientService.cs

@@ -1,6 +1,6 @@
 {
   "name": "com.pubnub.sdk",
-  "version": "8.1.0",
+  "version": "8.1.1",
   "displayName": "PubNub SDK",
   "description": "PubNub Real-time Cloud-Hosted Push API and Push Notification Client Frameworks",
   "unity": "2021.3",

PubNubUnity/Assets/PubNub/package.json

@@ -1 +1 @@
-8.1.0
+8.1.1