SDK
SDK Golang v2.x
1

Count #

Returns the number of other connections sharing the same subscription.

Arguments #

Copied to clipboard!
func (r *Realtime) Count(roomID string, options types.QueryOptions) (int, error)

Arguments Type Description
roomId
string
Subscription room ID
options
types.QueryOptions
Query options

options #

Additional query options

Option Type
(default)
Description
queuable
bool

(true)
Make this request queuable or not

Return #

Returns the number of active connections using the same provided subscription room.

Usage #

Copied to clipboard!
filters := json.RawMessage(`{}`)
listener := make(chan types.NotificationResult)
go func() {
  <-listener
}()
res, _ := kuzzle.Realtime.Subscribe(
  "nyc-open-data",
  "yellow-taxi",
  filters,
  listener,
  nil)
count, err := kuzzle.Realtime.Count(res.Room, nil)
if err != nil {
  log.Fatal(err)
} else {
  fmt.Printf("Currently %d active subscription\n", count)
}