diff --git a/AppSyncRealTimeClient/ConnectionProvider/AppsyncRealtimeConnection/RealtimeConnectionProvider+Websocket.swift b/AppSyncRealTimeClient/ConnectionProvider/AppsyncRealtimeConnection/RealtimeConnectionProvider+Websocket.swift
index 3c87b164..7a944f47 100644
--- a/AppSyncRealTimeClient/ConnectionProvider/AppsyncRealtimeConnection/RealtimeConnectionProvider+Websocket.swift
+++ b/AppSyncRealTimeClient/ConnectionProvider/AppsyncRealtimeConnection/RealtimeConnectionProvider+Websocket.swift
@@ -28,6 +28,9 @@ extension RealtimeConnectionProvider: AppSyncWebsocketDelegate {
                 return
             }
             #if os(watchOS)
+            AppSyncLogger.debug(
+                "[RealtimeConnectionProvider] on watchOS, received disconnect."
+            )
             self.updateCallback(event: .error(ConnectionProviderError.connection(
                 "This API uses low-level networking (websockets). Running on watchOS only works for specific circumstances.",
                 error)))
diff --git a/AppSyncRealTimeClient/Websocket/Starscream/StarscreamAdapter.swift b/AppSyncRealTimeClient/Websocket/Starscream/StarscreamAdapter.swift
index a75591c8..3ff0052e 100644
--- a/AppSyncRealTimeClient/Websocket/Starscream/StarscreamAdapter.swift
+++ b/AppSyncRealTimeClient/Websocket/Starscream/StarscreamAdapter.swift
@@ -23,6 +23,8 @@ public class StarscreamAdapter: AppSyncWebsocketProvider {
         }
     }
 
+    let watchOSConnectivityTimer: CountdownTimer
+    
     public init() {
         let serialQueue = DispatchQueue(label: "com.amazonaws.StarscreamAdapter.serialQueue")
         let callbackQueue = DispatchQueue(
@@ -32,6 +34,7 @@ public class StarscreamAdapter: AppSyncWebsocketProvider {
         self._isConnected = false
         self.serialQueue = serialQueue
         self.callbackQueue = callbackQueue
+        self.watchOSConnectivityTimer = CountdownTimer()
     }
 
     public func connect(urlRequest: URLRequest, protocols: [String], delegate: AppSyncWebsocketDelegate?) {
@@ -49,6 +52,30 @@ public class StarscreamAdapter: AppSyncWebsocketProvider {
             self.socket?.delegate = self
             self.socket?.callbackQueue = self.callbackQueue
             self.socket?.connect()
+            #if os(watchOS)
+            // On watchOS, if it takes longer than 5 seconds
+            // to connect, fail fast.
+            AppSyncLogger.debug(
+                "[StarscreamAdapter] Starting connectivity timer for watchOS for 3s"
+            )
+            self.watchOSConnectivityTimer.start(interval: 3) {
+                AppSyncLogger.debug(
+                    "[StarscreamAdapter] watchOS connectivity timer is up."
+                )
+                if !self._isConnected {
+                    AppSyncLogger.debug(
+                        "[StarscreamAdapter] watchOS subscriptions not connected after 3s."
+                    )
+                    self.serialQueue.async {
+                        self.delegate?.websocketDidDisconnect(provider: self, error: nil)
+                    }
+                } else {
+                    AppSyncLogger.debug(
+                        "[StarscreamAdapter] watchOS subscriptions are connected within 3s."
+                    )
+                }
+            }
+            #endif
         }
     }