# Enhanced Streams Quickstart

> Generate a client, list topics, and consume one Enhanced Stream.

Canonical: https://nolimitnodes.com/docs/api-reference/enhanced-streams/quickstart

## 1. Download the proto

```bash
curl -O https://nolimitnodes.com/protos/enhanced-streams.proto
```

## 2. Generate Python code

```bash
python -m pip install grpcio grpcio-tools protobuf

python -m grpc_tools.protoc \
  -I . \
  --python_out=. \
  --grpc_python_out=. \
  enhanced-streams.proto
```

Rename the generated module imports if your local generator replaces hyphens with underscores.

## 3. List topics

```python

channel = grpc.secure_channel(
    "stream-1.nln.clr3.org:443",
    grpc.ssl_channel_credentials(),
)
client = rpc.StreamServiceStub(channel)
metadata = [("x-api-key", "YOUR_API_KEY")]

response = client.ListTopics(pb.ListTopicsRequest(), metadata=metadata)
for topic in response.topics:
    print(topic.name, topic.proto_message_type)
```

## 4. Subscribe

```python

request = pb.SubscribeRequest(
    topic="prod.rpc.solana.system.transfers",
    format=pb.JSON,
)

for message in client.Subscribe(request, metadata=metadata):
    payload = json.loads(message.payload)
    print({
        "partition": message.partition,
        "offset": message.offset,
        "timestamp_ms": message.timestamp_ms,
        "payload": payload,
    })
```

## 5. Store progress

Write your event and its partition-offset pair in one database transaction.

After a disconnect, open a new stream. Enhanced Streams do not expose a client offset in `SubscribeRequest`, so downstream deduplication must use event identity and stored metadata.