Quick Start

import { FeedsClient } from "@stream-io/feeds-client";  const client = new FeedsClient("<API key>"); await client.connectUser({ id: "john" }, "<user token>");  // Create a feed (or get its data if exists) const feed = client.feed("user", "john"); // Subscribe to WebSocket events for state updates await feed.getOrCreate({ watch: true });  // Add activity await feed.addActivity({  text: "Hello, Stream Feeds!",  type: "post", });

import { StreamClient } from "@stream-io/node-sdk";  // Initialize the client const client = new StreamClient("<API key>", "<API secret>");  // Create a feed (or get its data if exists) const feed = client.feeds.feed("user", "john"); await feed.getOrCreate({ user_id: "john" });  // Add activity await client.feeds.addActivity({  type: "post",  feeds: ["user:john"],  text: "Hello, Stream Feeds!",  user_id: "john", });

import { FeedsClient } from "@stream-io/feeds-react-sdk";  const client = new FeedsClient("<API key>"); await client.connectUser({ id: "john" }, "<user token>");  // Create a feed (or get its data if exists) const feed = client.feed("user", "john"); // Subscribe to WebSocket events for state updates await feed.getOrCreate({ watch: true });  // Add activity await feed.addActivity({  text: "Hello, Stream Feeds!",  type: "post", });

import { FeedsClient } from "@stream-io/feeds-react-native-sdk";  const client = new FeedsClient("<API key>"); await client.connectUser({ id: "john" }, "<user token>");  // Create a feed (or get its data if exists) const feed = client.feed("user", "john"); // Subscribe to WebSocket events for state updates await feed.getOrCreate({ watch: true });  // Add activity await feed.addActivity({  text: "Hello, Stream Feeds!",  type: "post", });

// Create a timeline feed const timeline = client.feed("timeline", "john"); await timeline.getOrCreate();  // Add a reaction to activity await client.addReaction({  activity_id: "activity_123",  type: "like", });  // Add a comment to activity await client.addComment({  object_id: "activity_123",  object_type: "activity",  comment: "Great post!", });  // Add a reaction to comment await client.addCommentReaction({  id: "comment_123",  type: "love", });

// Create a timeline feed const timeline = client.feeds.feed("timeline", "john"); await timeline.getOrCreate({ user_id: "john" });  // Add a reaction to activity await client.feeds.addActivityReaction({  activity_id: "activity_123",  type: "like",  user_id: "john", });  // Add a comment to activity await client.feeds.addComment({  object_id: "activity_123",  object_type: "activity",  comment: "Great post!",  user_id: "john", });  // Add a reaction to comment await client.feeds.addCommentReaction({  id: "comment_456",  type: "love",  user_id: "john", });

// Create a notification feed const notifications = client.feed("notification", "john"); await notifications.getOrCreate();  // Mark notifications as read await notifications.markActivity({  mark_all_read: true, });

// Create a notification feed const notifications = client.feeds.feed("notification", "john"); await notifications.getOrCreate({ user_id: "john" });  // Mark notifications as read await notifications.markActivity({  mark_all_read: true,  user_id: "john", });

// Create a poll const feed = client.feed("user", "john"); const poll = await client.createPoll({  name: "What is your favorite color?",  options: [{ text: "Red" }, { text: "Blue" }, { text: "Green" }], });  // Attach it to an activity const activity = await feed.addActivity({  text: "What is your favorite color?",  type: "poll",  poll_id: poll.poll.id, });  // Vote await client.castPollVote({  poll_id: poll.poll.id,  activity_id: activity.activity.id,  vote: {  option_id: poll.poll.options[0].id,  }, });

const poll = await client.createPoll({  name: "What is your favorite color?",  options: [{ text: "Red" }, { text: "Blue" }, { text: "Green" }],  user_id: "john", });  // Attach it to an activity const activity = await client.feeds.addActivity({  feeds: ["user:john"],  text: "What is your favorite color?",  type: "poll",  poll_id: poll.poll.id,  user_id: "john", });  // Cast a vote on an existing poll await client.feeds.castPollVote({  activity_id: "activity_123",  poll_id: "poll_456",  user_id: "john",  vote: {  option_id: "option_789",  }, });

const feed = client.feed("user", "john"); await feed.addActivity({  type: "workout",  text: "Just finished my run",  custom: {  distance: 5.2,  duration: 1800,  calories: 450,  }, });

// Add custom activity with custom fields await client.feeds.addActivity({  type: "workout",  feeds: ["user:john"],  text: "Just finished my run",  user_id: "john",  custom: {  distance: 5.2,  duration: 1800,  calories: 450,  }, });

const feed = client.feed("user", "john"); // Subscribe to WebSocket events for state updates await feed.getOrCreate({ watch: true }); feed.state.subscribe((state) => {  // Called everytime the state changes  console.log(state); });  // or if you only want to observe part of the state feed.state.subscribeWithSelector(  (state) => ({  activities: state.activities,  }),  (state, prevState) => {  console.log(state.activities, prevState?.activities);  }, );  // Current state console.log(feed.state.getLatestValue());