cycle-http.js

import { div, h2, p } from '@cycle/dom';
import xs from 'xstream';

export function App(sources) {
  const request$ = xs.of({
    url: 'http://localhost:3000/ping',
    category: 'api',
    // progress: true,
  });

  const vtree$ = sources.HTTP
    .select('api')
    .map((response$) =>
      response$.replaceError((error) => {
        const res = { body: error.response };
        return xs.of(res);
      }),
    )
    .flatten()
    .debug((resp) => {
      console.log('GET Response', resp);
    })
    .map((res) => res.body)
    .startWith({
      value: 'Loading...',
    })
    .map((result) => div([h2('API data example'), p(JSON.stringify(result))]));

  const sinks = {
    DOM: vtree$,
    HTTP: request$,
  };

  return sinks;
}