benqoder_beam_client_pubsub_quickstart_subscribe_and_publish.ts

1import { Beam } from '@benqoder/beam';
2
3async function main() {
4  // Initialize the Beam client
5  const beam = new Beam({
6    apiKey: 'your-api-key-here',
7    workspaceId: 'your-workspace-id'
8  });
9
10  const topic = 'quickstart-topic';
11
12  // Subscribe to a topic
13  await beam.subscribe(topic, (message) => {
14    console.log(`Received message: ${message.data}`);
15  });
16
17  // Publish a message to the topic
18  await beam.publish(topic, {
19    data: 'Hello, Beam!'
20  });
21}
22
23main().catch(console.error);