Miss any of our Open RFC calls?Watch the recordings here! »


1.0.2 • Public • Published

styled with prettier Greenkeeper badge Build Status Coverage Status

Development Sponsored By:
Carbon Five

Signal Connect

Connect your signal graphs to ReactJs Components!


In your project:

npm install @rxreact/signal-connect --save


yarn add @rxreact/signal-connect

RxJS and React are peer dependencies and need to be installed seperately


Define a signal graph using the @rxreact/signal library.

Here's lets use the example from that project's README of a Signal Graph to represent a login component and user authentication.

  const signalGraph = new SignalGraphBuilder<SignalsType, Dependencies>()
      addDependency('api', api),
      addDerived('loginAttempts$', makeLoginAttempts, 'submitButton$', 'username$', 'password$'),
      addDerived('loginResponses$', makeLoginResponses, 'loginAttempts$', 'api'),
      addDerived('loginInProgress$', makeLoginInProgress, 'loginAttempts$', 'loginResponses$'),
      addDerived('loginSuccesses$', makeLoginSuccesses, 'loginResponses$'),
      addDerived('loginFailures$', makeLoginFailures, 'loginResponses$'),
      addDerived('authStatus$', makeAuthStatus, 'loginSuccesses$')
      loginInProgress$: false,
      loginFailureMessage$: '',
      username$: '',
      password$: '',
      authStatus$: { status: 'unauthorized' }

Now, let's say we have a login form component:

const LoginForm: React.SFC<{
  loginInProgress: boolean
  loginFailureMessage: string
  username: string
  password: string
  submitButton: () => undefined
  usernameChanged: (username: string) => undefined
  passwordChanged: (password: string) => undefined
}> = ({
}) => {
  const onSubmit = (event: React.FormEvent<HTMLFormElement>) => {
  return (
    <form onSubmit={onSubmit}>
      <label htmlFor="username">User name:</label>
        onChange={event => usernameChanged(event.target.value)}
      <label htmlFor="password">Password:</label>
        onChange={event => passwordChanged(event.target.value)}
      <button disabled={loginInProgress} type="submit">

We want to connect the signals from our signal graph to props on this component. Here's where we use @rxreact/signal-connect. @rxreact/signal-connect exports a single function called connect:

import { connect } from '@rxreact/signal-connect'

connect behaves a lot like connect from react-redux, creating data props that get updated from the latest values in the graph, and functions as props that we can call to send data back to the graph. The simples use of connect looks like this:

const ConnectedComponent = connect(
    loginInProgress: 'loginInProgress$',
    loginFailureMessage: 'loginFailureMessage$',
    username: 'username$',
    password: 'password$'
    usernameChanged: 'username$',
    passwordChanged: 'password$',
    submitButton: 'submitButton$'

The first object specifies data props that get updated as signals from the graph emit new values. (think mapStateToProps) The second objects specifies primary signals we use as entry points to send data back into the graph. In this case, the login form gets usernameChanged, passwordChanged, and submitButton as props. Each prop is a function, and when it's called (taking a signal parameter) it gets sent into the primary signals in the graph! (think mapDispatchToProps)

More Complex Usage

You may later want to have more control over assembling your props. In this case, you can can actually pass functions instead of objects, which get a single parameter than can be used to extract signals from the graph.

const ConnectedComponent = connect(
  outputs => ({
    loginInProgress: outputs('loginInProgress$'),
    loginFailureMessage: outputs('loginFailureMessage$'),
    username: outputs('username$'),
    password: outputs('password$')
  inputs => ({
    usernameChanged: inputs('username$'),
    passwordChanged: inputs('password$'),
    submitButton: inputs('submitButton$')

You also have access to an observable that represents the external props passed to the component in these functions:

const ConnectedProtectedAreaExtended = connect(
  (outputs, ownProps$: Observable<{ override: boolean }>) => {
    const authStatus$ = combineLatest(ownProps$, outputs('authStatus$')).pipe(
        ([{ override }, authStatus]): AuthStatus =>
          override ? { status: 'authorized', token: 'a token' } : authStatus
    const protectedResource$ = combineLatest(ownProps$, outputs('protected$')).pipe(
        ([{ override }, protectedResource]) =>
          override ? 'auth overridden' : protectedResource
    return {
      authStatus: authStatus$,
      protectedResource: protectedResource$

However, ideally you can use the simple version of connect in most cases, because signal graphs are flexible, and you can create many of your custom pieces/selections of data inside the graph itself!

Caveat Emptor

These libraries are still in development, use at your own risk





npm i @rxreact/signal-connect

DownloadsWeekly Downloads






Unpacked Size

80 kB

Total Files


Last publish


  • avatar
  • avatar
  • avatar