Receiving messages

Setting up

Firstly, we'll initialize our client stream

import { createClientStream } from "streamthing";

const res = await fetch("/api/get-streamthing-token");
const data = await res.json();

const stream = createClientStream({
  region: process.env.SERVER_REGION,
  id: process.env.SERVER_ID,
  token: data.token,
});
Creating listeners

Each listener, takes an event name and a callback, which will receive the event data.

stream.receive("event", callback);
Accepting messages

To accept messages simply pass a callback, which takes a message parameter, to the receive method.

stream.receive("event", (message) => {
  // Use message in any way
  console.log(message);
});
Full example
import { createClientStream } from "streamthing";

async function setupStream() {
  const res = await fetch("/api/get-streamthing-token");
  const data = await res.json();

  const stream = createClientStream({
    region: process.env.SERVER_REGION,
    id: process.env.SERVER_ID,
    token: data.token,
  });

  stream.receive("event", (message) => {
    console.log(message);
  });

  stream.disconnect(); // Make sure to disconnect in order to avoid hanging connections
}

setupStream();
Client stream