Method Subscribe

sdks/csharp/src/SpacetimeDBClient.cs:896–918

(ISubscriptionHandle handle, string[] querySqls)

        }

        QuerySetId? IDbConnection.Subscribe(ISubscriptionHandle handle, string[] querySqls)
        {
            if (!webSocket.IsConnected)
            {
                Log.Error("Cannot subscribe, not connected to server!");
                return null;
            }

            var id = stats.SubscriptionRequestTracker.StartTrackingRequest();
            // We use a distinct ID from the request ID as a sanity check that we're not
            // casting request IDs to query IDs anywhere in the new code path.
            var querySetId = querySetIdAllocator.Next();
            subscriptions[querySetId] = handle;
            webSocket.Send(new ClientMessage.Subscribe(
                new Subscribe
                {
                    RequestId = id,
                    QuerySetId = new QuerySetId(querySetId),
                    QueryStrings = querySqls.ToList(),
                }
            ));
            return new QuerySetId(querySetId);
        }

        /// Usage: SpacetimeDBClientBase.instance.OneOffQuery<Message>("SELECT * FROM table WHERE sender = \"bob\"");
        [Obsolete("This is replaced by ctx.Db.TableName.RemoteQuery(\"WHERE ...\")", false)]