loadObservable.js

import { from , to } from 'rxjs'
import { setObservableConfig, mapPropsStream } from 'recompose'
import { isEmpty } from 'lodash'
import { switchMap, map, startWith, tap, catchError } from 'rxjs/operators'

const load = mapPropsStream(props$ =>
  props$.pipe(
    switchMap(
      props =>
        isEmpty(props.userList)
          ? from(fetchUsers()).pipe(
              tap(users => props.setUserList(users)),
              map(users => ({ ...props, users, status: 'SUCCESS' })),
              startWith({ status: 'REQUEST', ...props })
            )
          : of(props).pipe(map(props => ({...props, status: 'SUCCESS'})))
    ),
    catchError(() => ({ status: 'ERROR', message: 'Looks like our service is down' }))
  )
)