fix websocket callback

awslabs · May 13, 2024 · 979d775 · 979d775
1 parent bf10b08
commit 979d775
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift b/Source/AwsCommonRuntimeKit/mqtt/Mqtt5Client.swift
@@ -456,10 +456,10 @@ internal func MqttClientWebsocketTransform(
     _ complete_fn: (@convention(c) (OpaquePointer?, Int32, UnsafeMutableRawPointer?) -> Void)?,
     _ complete_ctx: UnsafeMutableRawPointer?) {
 
-    let client = Unmanaged<Mqtt5Client>.fromOpaque(complete_ctx!).takeUnretainedValue()
+    let client = Unmanaged<Mqtt5Client>.fromOpaque(user_data!).takeUnretainedValue()
 
     // validate the callback flag, if flag is false, return
-        client.rwlock.read {
+    client.rwlock.read {
         if client.callbackFlag == false { return }
 
         guard let request else {