Method Connect

sdks/csharp/src/WebSocket.cs:149–388

(string? auth, string host, string nameOrAddress, ConnectionId connectionId, Compression compression, bool light, bool? confirmedReads)

#endif

        public async Task Connect(string? auth, string host, string nameOrAddress, ConnectionId connectionId, Compression compression, bool light, bool? confirmedReads)
        {
#if UNITY_WEBGL && !UNITY_EDITOR
            if (_isConnecting || _isConnected) return;

            _isConnecting = true;
            _cancelConnectRequested = false;
            try
            {
                var uri = $"{host}/v1/database/{nameOrAddress}/subscribe?connection_id={connectionId}&compression={compression}";
                if (light) uri += "&light=true";
                if (confirmedReads.HasValue)
                {
                    // Ensure to transmit the bool as lowercase.
                    var enabled = confirmedReads.GetValueOrDefault() ? "true" : "false";
                    uri += $"&confirmed={enabled}";
                }

                _socketId = new TaskCompletionSource<int>();
                var callbackPtr = Marshal.GetFunctionPointerForDelegate((Action<int>)OnSocketIdReceived);
                WebSocket_Connect(host, uri, _options.Protocol, auth, callbackPtr);
                _webglSocketId = await _socketId.Task;
                if (_webglSocketId == -1)
                {
                    dispatchQueue.Enqueue(() => OnConnectError?.Invoke(
                        new Exception("Failed to connect WebSocket")));
                }
                else if (_cancelConnectRequested)
                {
                    // If cancel was requested before open, proactively close now.
                    WebSocket_Close(_webglSocketId, (int)WebSocketCloseStatus.NormalClosure, "Canceled during connect.");
                }
            }
            catch (Exception e)
            {
                dispatchQueue.Enqueue(() => OnConnectError?.Invoke(e));
            }
            finally
            {
                _isConnecting = false;
            }
        // Events will be handled via UnitySendMessage callbacks
#else
            var uri = $"{host}/v1/database/{nameOrAddress}/subscribe?connection_id={connectionId}&compression={compression}";
            if (light)
            {
                uri += "&light=true";
            }
            if (confirmedReads.HasValue)
            {
                // Ensure to transmit the bool as lowercase.
                var enabled = confirmedReads.GetValueOrDefault() ? "true" : "false";
                uri += $"&confirmed={enabled}";
            }
            var url = new Uri(uri);
            Ws.Options.AddSubProtocol(_options.Protocol);

            _connectCts = new CancellationTokenSource(10000);