First, we'll create a new utility module called WebAPIUtils
. Create WebAPIUtils.js
in the ~/snapterest/source/utils/
directory:
var SnapkiteStreamClient = require('snapkite-stream-client'); var TweetActionCreators = require('../actions/TweetActionCreators'); function initializeStreamOfTweets() { SnapkiteStreamClient.initializeStream(TweetActionCreators.receiveTweet); } module.exports = { initializeStreamOfTweets: initializeStreamOfTweets };
In this utility module, we first import the SnapkiteStreamClient
library and TweetActionCreators
. Then, we create the initializeStreamOfTweets()
function that initializes a stream of new tweets, just like in the componentDidMount()
method of the Stream
component, except with one key difference: whenever SnapkiteStreamClient
receives a new tweet, it calls the TweetActionCreators.receiveTweet
method that passes a new tweet to it as an argument:
SnapkiteStreamClient.initializeStream(TweetActionCreators.receiveTweet);
Remember...