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)
}