# at.adsb.broadcast.subscribeEvents

> Published by [adsb.at](https://lexicon.garden/identity/did:plc:32thk4eifx4ou6mxevswgjhg)

✓ This is the authoritative definition for this NSID.

## Description

Ephemeral event stream from a receiver station. Emits batched aircraft operations per poll cycle. Does not write to any repository.

## Links

- [View on Lexicon Garden](https://lexicon.garden/lexicon/did:plc:32thk4eifx4ou6mxevswgjhg/at.adsb.broadcast.subscribeEvents)
- [Documentation](https://lexicon.garden/lexicon/did:plc:32thk4eifx4ou6mxevswgjhg/at.adsb.broadcast.subscribeEvents/docs)
- [Examples](https://lexicon.garden/lexicon/did:plc:32thk4eifx4ou6mxevswgjhg/at.adsb.broadcast.subscribeEvents/examples)

## Definitions

### `at.adsb.broadcast.subscribeEvents#info`

**Type**: `object`

| Property | Type | Required | Description |
|----------|------|----------|-------------|
| `name` | `string` | Yes | Operational info message name. |
| `message` | `string` | No | Human-readable info message. |

### `at.adsb.broadcast.subscribeEvents`

**Type**: `subscription`

Subscribe to realtime events from this receiver station.

```json
{
  "type": "subscription",
  "errors": [
    {
      "name": "FutureCursor"
    },
    {
      "name": "ConsumerTooSlow"
    }
  ],
  "message": {
    "schema": {
      "refs": [
        "#event",
        "#identity",
        "#info"
      ],
      "type": "union"
    }
  },
  "parameters": {
    "type": "params",
    "properties": {
      "cursor": {
        "type": "integer",
        "description": "Not currently used for backfill. Reserved for future use."
      }
    }
  },
  "description": "Subscribe to realtime events from this receiver station."
}
```

### `at.adsb.broadcast.subscribeEvents#event`

**Type**: `object`

A batch of operations from a single poll cycle.

| Property | Type | Required | Description |
|----------|------|----------|-------------|
| `ops` | `array` | Yes | List of operations in this batch. |
| `seq` | `integer` | Yes | The stream sequence number of this message. |
| `time` | `string` (datetime) | Yes | Timestamp of the poll cycle that produced this batch. |
| `station` | `ref` → `com.atproto.repo.strongRef` | Yes | Strong reference to the emitting receiver's at.adsb.receiver.station record. |

### `at.adsb.broadcast.subscribeEvents#identity`

**Type**: `object`

Represents a station coming online or updating its identity.

| Property | Type | Required | Description |
|----------|------|----------|-------------|
| `did` | `string` (did) | Yes | DID of the station. |
| `seq` | `integer` | Yes | The stream sequence number of this message. |
| `time` | `string` (datetime) | Yes | Timestamp of when this identity event was produced. |
| `station` | `ref` → `com.atproto.repo.strongRef` | No | Strong reference to the station record. |

### `at.adsb.broadcast.subscribeEvents#broadcastOp`

**Type**: `object`

A single operation within a broadcast event.

| Property | Type | Required | Description |
|----------|------|----------|-------------|
| `action` | `string` | Yes | The type of operation. |
| `record` | `unknown` | Yes | The record payload. Shape determined by record's $type field. |

## Raw Schema

```json
{
  "id": "at.adsb.broadcast.subscribeEvents",
  "defs": {
    "info": {
      "type": "object",
      "required": [
        "name"
      ],
      "properties": {
        "name": {
          "type": "string",
          "maxLength": 64,
          "description": "Operational info message name.",
          "knownValues": [
            "OutdatedCursor"
          ]
        },
        "message": {
          "type": "string",
          "maxLength": 1024,
          "description": "Human-readable info message."
        }
      }
    },
    "main": {
      "type": "subscription",
      "errors": [
        {
          "name": "FutureCursor"
        },
        {
          "name": "ConsumerTooSlow"
        }
      ],
      "message": {
        "schema": {
          "refs": [
            "#event",
            "#identity",
            "#info"
          ],
          "type": "union"
        }
      },
      "parameters": {
        "type": "params",
        "properties": {
          "cursor": {
            "type": "integer",
            "description": "Not currently used for backfill. Reserved for future use."
          }
        }
      },
      "description": "Subscribe to realtime events from this receiver station."
    },
    "event": {
      "type": "object",
      "required": [
        "seq",
        "station",
        "time",
        "ops"
      ],
      "properties": {
        "ops": {
          "type": "array",
          "items": {
            "ref": "#broadcastOp",
            "type": "ref"
          },
          "description": "List of operations in this batch."
        },
        "seq": {
          "type": "integer",
          "description": "The stream sequence number of this message."
        },
        "time": {
          "type": "string",
          "format": "datetime",
          "description": "Timestamp of the poll cycle that produced this batch."
        },
        "station": {
          "ref": "com.atproto.repo.strongRef",
          "type": "ref",
          "description": "Strong reference to the emitting receiver's at.adsb.receiver.station record."
        }
      },
      "description": "A batch of operations from a single poll cycle."
    },
    "identity": {
      "type": "object",
      "required": [
        "seq",
        "did",
        "time"
      ],
      "properties": {
        "did": {
          "type": "string",
          "format": "did",
          "description": "DID of the station."
        },
        "seq": {
          "type": "integer",
          "description": "The stream sequence number of this message."
        },
        "time": {
          "type": "string",
          "format": "datetime",
          "description": "Timestamp of when this identity event was produced."
        },
        "station": {
          "ref": "com.atproto.repo.strongRef",
          "type": "ref",
          "description": "Strong reference to the station record."
        }
      },
      "description": "Represents a station coming online or updating its identity."
    },
    "broadcastOp": {
      "type": "object",
      "required": [
        "action",
        "record"
      ],
      "properties": {
        "action": {
          "type": "string",
          "maxLength": 16,
          "description": "The type of operation.",
          "knownValues": [
            "create",
            "update",
            "delete"
          ]
        },
        "record": {
          "type": "unknown",
          "description": "The record payload. Shape determined by record's $type field."
        }
      },
      "description": "A single operation within a broadcast event."
    }
  },
  "$type": "com.atproto.lexicon.schema",
  "lexicon": 1,
  "description": "Ephemeral event stream from a receiver station. Emits batched aircraft operations per poll cycle. Does not write to any repository."
}
```
