fetchRepos.js

export function fetchReposByUser(sources) {
  const user$ = sources.ACTION
    .filter(action => action.type === ActionTypes.REQUESTED_USER_REPOS)
    .map(action => action.payload.user);

  const request$ = user$
    .map(user => ({
      url: `https://api.github.com/users/${user}/repos`,
      category: 'users'
    }));

  const response$ = sources.HTTP
    .select('users')
    .flatten();

  const action$ = xs.combine(response$, user$)
    .map(arr => actions.receiveUserRepos(arr[1], arr[0].body));

  return {
    ACTION: action$,
    HTTP: request$
  }
}

index.js

import xs from 'xstream';
import { combineCycles } from 'redux-cycles';
import * as actions from '../actions';
import * as ActionTypes from '../ActionTypes';

export function fetchApiStatus(sources) {
  const request$ = sources.ACTION
    .filter(action => action.type === ActionTypes.REQUESTED_API_STATUS)
    .map(() => {
      return {
        category: 'status',
        url: 'https://api.github.com/users/aaronmcadam',
        accept: 'application/json',
        type: 'application/json; charset=utf-8',
        // progress: true,
        // headers: {
        //   Authorization: 'Bearer 1234abcd',
        // },
        // withCredentials: true,
      }
    })

  const action$ = sources.HTTP
    .select('status')
    .flatten()
    .map((response) => actions.receiveApiStatus(response.body))

  return {
    ACTION: action$,
    HTTP: request$
  }
}

export default combineCycles(fetchApiStatus);