RxJS with React Hooks for state management
Tags: react, rxjs, javascript, webdev
Published: 2019-11-11 21:10:54

---
title: RxJS with React Hooks for state management
published: true
date: 2019-11-11 19:30:19 UTC
tags: react,rxjs,javascript,webdev 
canonical_url: https://blog.logrocket.com/rxjs-with-react-hooks-for-state-management/
cover_image: https://thepracticaldev.s3.amazonaws.com/i/kv631wkkk38dw1gney58.jpeg
---
**Written by [Ebenezer Don](https://blog.logrocket.com/author/ebenezerdon/)**✏️

In this article, we’ll cover the basics of RxJS and how to integrate it with React applications using React Hooks for state management. We’ll do this by building a demo chat application. Our chat application will have three components that will communicate with each other through RxJS.

Our final app will look like this:

![Our Final Chat App](https://i1.wp.com/blog.logrocket.com/wp-content/uploads/2019/11/rxjs-react-chat-app.gif?resize=600%2C563&ssl=1)

## Let’s start by explaining **RxJS**

RxJS (Reactive Extensions Library for JavaScript) is a useful library for reactive programming. The RxJS documentation uses this definition:

> RxJS is a library for reactive programming using Observables, to make it easier to compose asynchronous or callback-based code.

Reactive programming is an event-based paradigm that allows us to run asynchronous sequences of events as soon as data is pushed to a consumer.

To be able to use RxJS for state management in React, it is important to understand the following key terms:

#### Observable

An Observable is a data stream that houses data that can be passed through different threads. In our demo app, we’ll be using an Observable to supply data to our different components.

#### Observer

An Observer consumes the data supplied by an Observable. In our demo app, we’ll be using our `setState` Hook to consume data from our Observable.

#### Subscription

In order for our Observer to consume data from our Observable, we’ll have to subscribe it to the Observable. In our demo app, we’ll be using the `subscribe()` method to subscribe our `setState` Observer to our Observable.

[![LogRocket Free Trial Banner](https://i0.wp.com/blog.logrocket.com/wp-content/uploads/2017/03/f760c-1gpjapknnuyhu8esa3z0jga.png?resize=1200%2C280&ssl=1)](https://logrocket.com/signup/)

## Setting up our application

The best way to understand RxJS is to use it.

Let’s start by creating a new react application. If you don’t have create-react-app installed, on your terminal, run:

```jsx
>npm i -g create-react-app
```

Next:

```jsx
create-react-app rxjs_react_chat
```

This will generate a new react application using create-react-app.

To start our application, let’s navigate to our new app directory and run the command `npm start`:

```jsx
cd rxjs_react_chat
npm start
```

In our new generated app directory, let’s navigate to `/src/`. Since we’ll be working with multiple components, let’s set up `BrowserRouter` for navigating through different routes.

Let’s run the following command:

```jsx
npm install --save react-router-dom
```

Next, we’ll edit our `/src/App.js` file to look like this:

```jsx
// /src/App.js
import  React  from  'react';
import { BrowserRouter, Route, Switch } from  'react-router-dom';
import  './index.css';

const  App  = () => (
  <BrowserRouter />
);

export  default  App;
```

In our `src` folder, let’s create a **store** directory, `src/store`. This is where we’ll house our store.

Next, let’s create a `chat.js` file for our chat operations, `src/store/chat.js`. In our `chat.js` file, we’ll import `Subject` from `rxjs` and create a new variable from the Subject class:

```jsx
import { Subject } from 'rxjs';

const subject = new Subject();
```

### Subjects and Subscriptions

An RxJS Subject can act as both an Observable and an Observer at the same time. In this way, values can be multicasted to many Observers from it so that when a Subject receives any data, that data can be forwarded to every Observer subscribed to it.

In our application, we’ll be subscribing our different React Hooks `setState` functions to our RxJS Subject so that when it receives any data, it forwards that data to every state associated with our `setState` function.

Let’s create a `subscribe` method for this purpose:

```jsx
import { Subject } from 'rxjs'

const subject = new Subject();

const chatStore = {
  subscribe: setState => subject.subscribe(setState)
}
```

Next, we’ll create an object for our initial chat state:

```jsx
import { Subject } from 'rxjs'

const subject = new Subject();

const initialState = {
  data: [],
  newDataCount: 0,
}; 

let state = initialState;

const chatStore = {
  subscribe: setState => subject.subscribe(setState)
}
```

We’ll use the `data` key to hold our array of message objects. These message objects will contain the values `person` (to specify who a message is from) and `text` (to store the message text).

Here’s what our object will look like:

```jsx
{
  person: 'first-person',
  text: 'How are you?'
}
```

In our `initialState` object, the `newDataCount` will be used by our notification functionality to tell when new data has been pushed to our state.

Now that we have our state object, let’s create an `init()` method that will initialize our component’s state whenever it’s mounted:

```jsx
...
const chatStore = {
  init: () => subject.next(state),
  subscribe: setState => subject.subscribe(setState)
}
```

The `Subject.next()` method is used to feed a new value to the Subject. When we call the `next()` method with a value as its parameter, that value is multicasted to all Observers subscribed to the Subject.

In our application, we’ll call both the `subscribe()` and `init()` methods whenever our component mounts in order to set our state to what we have in our chat store.

### Adding data to the store

Next we’ll create a `sendMessage()` method. We’ll call this method whenever our users hit the send message button. Our `sendMessage()` method will receive a `message` argument, which we’ll append to our `state.data` array. Remember that our `message` argument is an object with keys `person` and `text`.

Let’s create our object with the following code block:

```jsx
...
const chatStore = {
  init: () => subject.next(state),
  subscribe: setState => subject.subscribe(setState),
  sendMessage: message => {
    state = {
      ...state,
      data: [...state.data, message],
      newDataCount: state.newDataCount + 1
     };
     subject.next(state);
  }
};
```

In our new block, we appended our `message` object to our `state.data` array, then we incremented our `newDataCount`.

Now that we have our `newDataCount` incremented every time a new message is sent by a user, we’ll also add a functionality for resetting our new data count each time the messages are viewed so that when `person 1` sends a new message and `person 2` reads the message, the data count resets to `0`.

To do this, in our `init()` method, we’ll assign the `newDataCount` key in our state the value of `0` each time a new component that subscribes to our `Subject` is mounted:

```jsx
...
const chatStore = {
  init: () => {
    state = {...state, newDataCount: 0},
    subject.next(state)
  },
  subscribe: setState => subject.subscribe(setState),
  sendMessage: message => {
    state = {
      ...state,
      data: [...state.data, message],
      newDataCount: state.newDataCount + 1
    };
    subject.next(state);
  }
};
```

### Removing data from the store

Next, we’ll add a method for clearing all messages. We’ll call it `clearChat()`:

```jsx
...
const chatStore = {
  init: () => {
    <b>state = {...state, newDataCount: 0},</b>
    subject.next(state)
  },
  subscribe: setState => subject.subscribe(setState),
  sendMessage: message => {
    state = {
      ...state,
      data: [...state.data, message],
      newDataCount: state.newDataCount + 1
    };
    subject.next(state);
  },
  clearChat: () => {
    state = initialState;
    subject.next(state);
  },
  initialState
};
```

We’ve also added our initial state to the `chatStore` object. We’ll use this to set our initial state value when defining our `chatState` with the `useState()` Hook.

Finally, let’s export the `chatStore` object. Our `src/store/chat.js` file should now look like this:

```jsx
// src/store/chat.js

import { Subject } from 'rxjs';

const subject = new Subject();
const initialState = {
  status: '',
  data: [],
  newDataCount: 0,
  error: ''
};

let state = initialState;

const chatStore = {
  init: () => {
    state = {...state, newDataCount: 0}
    subject.next(state)
  },
  subscribe: setState => subject.subscribe(setState),
  sendMessage: message => {
    state = {
      ...state,
      data: [...state.data, message],
      newDataCount: state.newDataCount + 1
    };
    subject.next(state);
  },
  clearChat: () => {
    state = {...state, data: []};
    subject.next(state);
  },
  initialState
};

export default chatStore;
```

## Using the store

Now that we’ve set up our chat store, in the following steps, we’ll be creating our components to utilize the store and its methods.

First, let’s modify our `src/index.css` file to look like this:

```jsx
.container {
  font-family: Arial, Helvetica, sans-serif;
  padding: 1em;
}

.chat-box {
  background: #202020;
  margin: auto;
  padding: 2em;
  height: 35em;
  width: 95%;
  border-radius: 20px;
  overflow-y: scroll;
}

.first-person, .second-person {
  display: inline-block;
  color: #fff;
  height: 25px;
  min-width: 20%;
  max-width: 60%;
  padding: 20px;
  text-align: center;
  vertical-align: middle;
  border-radius: 30px;
}

.first-person {
  background: rgb(0, 173, 231);
}

.second-person {
  background: #06c406;
  float: right;
}

.clear{ 
  clear: both;
  display: block;  
  content: "";
  width: 100%;  
}

.switcher-div {
  padding-top: 1em;
  text-align: center;
}

#messageForm {
  text-align: center;
  margin-top: 1.5em;
}

#messageForm input {
  height: 2em;
  width: 23em;
  border-radius: 3em;
  padding: 1em;
}

#messageForm button {
  margin-left: 2em;
  height: 2.7em;
  width: 6.2em;
  border-radius: 25px;
  border: none;
  cursor: pointer;
}

.clear-button {
  background: #d40000;
  color: #fff;
  float: right;
  margin-right: 3em;
  text-align: center;
  height: 2.5em;
  width: 8em;
  cursor: pointer;
}

.switcher {
  background: #cecece;
  color: #141414;
  height: 2.5em;
  width: 6em;
  border-radius: 25px;
  border: 1 px solid black;
  margin-right: 1em;
  cursor: pointer;
}

.notify {
  position: absolute;
  background: #db0000;
  color: white;
  height: 1em;
  width: 1em;
  border-radius: 100%;
  padding: 0.15em;
  margin-left: 0.5em;
  margin-top: -0.5em;
}
```

In our `src` folder, let’s create a components directory, `src/components`. This is where we’ll house all our components. We’ll need three components for our application:

- A component for the first person
- A component for the second person
- A component for switching between the two person components

In our `src/components` directory, let’s create a new file, `FirstPerson.js`, for our first person component. Our new component should look like this:

```jsx
import  React, { useState } from  "react";

const FirstPerson = () => {
  const [chatState, setChatState] = useState({});
  return (
    <div className="container">
      <h2>Mycroft</h2>
      <div className="chat-box">
        {chatState.data.map(message => (
          <div>
            <p className={message.person}>{message.text}</p>
            <div className="clear"></div>
          </div>
        ))}
      </div>
      <form id="messageForm">
        <input
          type="text"
          id="messageInput"
          name="messageInput"
          placeholder="type here..."
          required
        />
        <button type="submit">Send</button> <br />
      </form>
    </div>
  );
}

export  default  FirstPerson;
```

### Subscribing to our store and retrieving existing data

In the next block, we’ll import our `chatStore` and use its `initialState` property as our default `chatState` value.

Then, in our `useLayoutEffect()` Hook, we’ll subscribe our `setChatState` function to our **chat store** using the `chatStore.subscribe()` method and, finally, use the `chatStore.init()` method to initialize our component’s `chatState`:

```jsx
import React, { useState, useLayoutEffect } from "react";
<b>import chatStore from '../store/chat';</b>

const FirstPerson = () => {
  const [chatState, setChatState] = useState(chatStore.initialState);

  useLayoutEffect(()=> {
    chatStore.subscribe(setChatState);
    chatStore.init();
  },[]);

  return (...)
```

We are making use of the `useLayoutEffect()` Hook to send data to our `chatState` _before_ our component is rendered.

To preview the result of our code so far, let’s create an `index.js` file in our `src/components` folder and export our `FirstPerson` component from it:

```jsx
// src/components/index.js
export {  default as FirstPerson } from './FirstPerson';
```

Next, we’ll import our `FirstPerson` component in our `src/App.js` file and add it to a route path:

```jsx
// /src/App.js
import  React  from  'react';
import { BrowserRouter, Route, Switch } from  'react-router-dom';
import { FirstPerson } from './components';
import  './index.css';

const  App  = () => (
    <BrowserRouter>
      <>
        <Switch>
          <Route path="/" component={FirstPerson} exact />
          <Route path="/first-person" component={FirstPerson} exact />
        </Switch>
      </>
   </BrowserRouter>
);

export  default  App;
```

Now, when we run our app and navigate to the `/` or `/first-person` route, we should see:

![First Person Component In Our Chat App](https://i0.wp.com/blog.logrocket.com/wp-content/uploads/2019/11/firstperson-component-chat-app.png?resize=600%2C498&ssl=1)

Back to our `/src/components/FirstPerson.js` file. Let’s add an `onFormSubmit()` method. We’ll call this method whenever our user clicks the `send` button:

```jsx
...

const FirstPerson = () => {
  const [chatState, setChatState] = useState(chatStore.initialState);

  useLayoutEffect(()=> {
    chatStore.subscribe(setChatState);
    chatStore.init();
  },[]);

  const onFormSubmit = e => {
    e.preventDefault();
    const messageObject = {
      person: 'first-person',
      text: e.target.elements.messageInput.value.trim(),
    };
    chatStore.sendMessage(messageObject);
    document.getElementById('messageForm').reset();
  };

  return (
    ...
      <form id="messageForm" onSubmit={onFormSubmit}>
        <input
          type="text"
          id="messageInput"
          name="messageInput"
          placeholder="type here..."
          required
        />
        <button type="submit">Send</button> <br />
      </form>
    </div>
  );
}

export default FirstPerson;
```

Our `onFormSubmit()` function creates a message object with the `person` and `text` keys, then uses our `chatStore.sendMessage()` method to add our new message to the chat store.

Next, we’ll add a button that we’ll use to call our `chatStore.clearChat()` method. We’ll use this to clear our chat store whenever the `clear` button is clicked.

Let’s add the following block of code right after the `</form>` closing tag:

```jsx
<button className="clear-button" onClick={() => chatStore.clearChat()}>
  Clear Chat
</button>
```

Our `src/components/FirstPerson.js` file should now look like this:

```jsx
import React, { useState, useLayoutEffect } from "react";
import chatStore from '../store/chat';

const FirstPerson = () => {
  const [chatState, setChatState] = useState(chatStore.initialState);

  useLayoutEffect(()=> {
    chatStore.subscribe(setChatState);
    chatStore.init();
  },[]);

  const onFormSubmit = e => {
    e.preventDefault();
    const messageObject = {
      person: 'first-person',
      text: e.target.elements.messageInput.value.trim(),
    };
    chatStore.sendMessage(messageObject);
    document.getElementById('messageForm').reset();
  };

  return (
    <div className="container">
      <h2>Mycroft</h2>
      <div className="chat-box">
        {chatState.data.map(message => (
          <div>
            <p className={message.person}>{message.text}</p>
            <div className="clear"></div>
          </div>
        ))}
      </div>
      <form id="messageForm" onSubmit={onFormSubmit}>
        <input
          type="text"
          id="messageInput"
          name="messageInput"
          placeholder="type here..."
          required
        />
        <button type="submit">Send</button> <br />
      </form>
      <button className="clear-button" onClick={() => chatStore.clearChat()}>
        Clear Chat
      </button>
    </div>
  );
}

export default FirstPerson;
```

When we preview our app on our browser, we should now be able to send a message to our store and clear all messages:

[IMAGE]

## Sharing data among components

Now that we’ve seen how to retrieve data from our store and add data to it, let’s create our `SecondPerson` component to demonstrate how this data can be shared between different components.

The `SecondPerson` component has the same functionality as the `FirstPerson` component, so we’ll only change our `person` value in our `messageObject` to `second-person` and the name of our user from `Mycroft` to `Cortana` in the `<h2>` tag inside our `container` div.

To do this, let’s create a new file, `src/components/SecondPerson.js`, and paste the following code blocks:

```jsx
import React, { useState, useLayoutEffect } from "react";
import chatStore from '../store/chat';

const SecondPerson = () => {
  const [chatState, setChatState] = useState(chatStore.initialState);

  useLayoutEffect(()=> {
    chatStore.subscribe(setChatState);
    chatStore.init();
  },[]);

  const onFormSubmit = e => {
    e.preventDefault();
    const messageObject = {
      person: 'second-person',
      text: e.target.elements.messageInput.value.trim(),
    };
    chatStore.sendMessage(messageObject);
    document.getElementById('messageForm').reset();
  };

  return (
    <div className="container">
      <h2 style={{float: 'right'}}>Cortana</h2>
      <div className="chat-box">
        {chatState.data.map(message => (
          <div>
            <p className={message.person}>{message.text}</p>
            <div className="clear"></div>
          </div>
        ))}
      </div>
      <form id="messageForm" onSubmit={onFormSubmit}>
        <input
          type="text"
          id="messageInput"
          name="messageInput"
          required
        />
        <button type="submit">Send</button> <br />
      </form>
      <button className="clear-button" onClick={() => chatStore.clearChat()}>
        Clear Chat
      </button>
    </div>
  );
}

export default SecondPerson;
```

Next, we’ll need to create our `PersonSwitcher` component to switch between our two components. In our `src/components` directory, let’s create a new file, `PersonSwitcher.js`, and paste the following code blocks:

```jsx
// src/components/PersonSwitcher.js
import React, {useState, useEffect} from 'react';
import { Link } from 'react-router-dom';
import chatStore from '../store/chat';

const PersonSwitcher = () => {
  const [chatState, setChatState] = useState(chatStore.initialState);
  const location = window.location.href.split('/')[3];

  useEffect(() => {
    chatStore.subscribe(setChatState);
    chatStore.init();
  }, [])

  const messageNotification = chatState.newDataCount > 0
    && (<span className="notify">{chatState.newDataCount}</span>);

  return (
    <div className="switcher-div">
      <Link to="/first-person"><button className="switcher">
        Person1
        {location !== 'first-person' && location.length > 1 && messageNotification}
      </button></Link>
      <Link to="/second-person"><button className="switcher">
        Person2
        {location !== 'second-person' && messageNotification}        
      </button></Link>
    </div>
  );
}

export default PersonSwitcher;
```

Notice that we’ve also created a `chatState` for our component, which we’ve subscribed to our `chatStore`. We’ll need this to notify our component when a new message is added to our chat store. Note how we added a `messageNotification` variable that utilizes our `newDataCount` property from our chat store.

Now, we can export our two new components from our `src/components/index.js` folder:

```jsx
export { default as FirstPerson } from './FirstPerson';
export { default as SecondPerson } from './SecondPerson';
export { default as PersonSwitcher } from './PersonSwitcher';
```

Finally, let’s import our new components in our `src/App.js` and add them to our `BrowserRouter`. Our `App.js` file should now look like this:

```jsx
import React from 'react';
import { BrowserRouter as Router, Route, Switch } from 'react-router-dom';
import { FirstPerson, SecondPerson, PersonSwitcher } from './components';
import './App.css';

const App = () => (
  <Router>
    <>
      <PersonSwitcher />
      <Switch>
        <Route path="/" component={FirstPerson} exact />>
        <Route path="/first-person" component={FirstPerson} exact />>
        <Route path="/second-person" component={SecondPerson} exact />>
      </Switch>
    </>
  </Router>
);

export default App;
```

Now when we run our application, we’ll be able to switch between components, receive new message count when we send a message, and clear all messages using the `clear` button:

![Our Final Chat App](https://i1.wp.com/blog.logrocket.com/wp-content/uploads/2019/11/rxjs-react-chat-app.gif?resize=600%2C563&ssl=1)

## Conclusion

In this article, we’ve covered the basics of RxJS and have demonstrated how to use it for state management in React by building a component-based chat application. Here’s a [link to the GitHub repo](https://github.com/ebenezerdon/rxjs_react_chat) for our demo app.

Compared to other alternatives like Redux, I’ve found the use of RxJS and Hooks to be a really effective and straightforward way to manage state in React applications.

To learn more about RxJS, check out the following articles:

- [How to use RxJS operators to consume Observables in your workflow](https://dev.to/bnevilleoneill/how-to-use-rxjs-operators-to-consume-observables-in-your-workflow-39bk)
- [Understanding RxJS Observables and why you need them](https://dev.to/bnevilleoneill/understanding-rxjs-observables-and-why-you-need-them-17gp)

Happy hacking!

* * * 
**Editor's note:** Seeing something wrong with this post? You can find the correct version [here](https://blog.logrocket.com/rxjs-with-react-hooks-for-state-management/).

## Plug: [LogRocket](https://logrocket.com/signup/), a DVR for web apps
 
![LogRocket Dashboard Free Trial Banner](https://i2.wp.com/blog.logrocket.com/wp-content/uploads/2017/03/1d0cd-1s_rmyo6nbrasp-xtvbaxfg.png?resize=1200%2C677&ssl=1)
 
[LogRocket](https://logrocket.com/signup/) is a frontend logging tool that lets you replay problems as if they happened in your own browser. Instead of guessing why errors happen, or asking users for screenshots and log dumps, LogRocket lets you replay the session to quickly understand what went wrong. It works perfectly with any app, regardless of framework, and has plugins to log additional context from Redux, Vuex, and @ngrx/store.
 
In addition to logging Redux actions and state, LogRocket records console logs, JavaScript errors, stacktraces, network requests/responses with headers + bodies, browser metadata, and custom logs. It also instruments the DOM to record the HTML and CSS on the page, recreating pixel-perfect videos of even the most complex single-page apps.
 
[Try it for free](https://logrocket.com/signup/).
* * *
The post [RxJS with React Hooks for state management](https://blog.logrocket.com/rxjs-with-react-hooks-for-state-management/) appeared first on [LogRocket Blog](https://blog.logrocket.com).