for react usage:

https://github.com/acdlite/recompose/blob/master/docs/API.md#componentfromstreamwithconfig

basic hello world

import React from "react";
import { componentFromStream } from "recompose";

const Potato = componentFromStream(props$ =>
  props$.map(props => <div>{props.message}</div>)
);
export default () => <Potato message="hello world" />;

a very basic rxreact timer using Observable.interval

import React from "react";
import { setObservableConfig, componentFromStream } from "recompose";
import rxjsConfig from "recompose/rxjsObservableConfig";
import { Observable } from "rxjs";

setObservableConfig(rxjsConfig);

const Potato = componentFromStream(props =>
  Observable.interval(1000).map(count => <h1>{count}</h1>)
);

export default Potato;

typewriter effect example using Observable.zip, .from, .interval, .scan, .switchMap and .map

import React from "react";
import rxjsConfig from "recompose/rxjsObservableConfig";
import { Observable } from "rxjs";
import { setObservableConfig, componentFromStream } from "recompose";

setObservableConfig(rxjsConfig);

const createTypewriter = message =>
  Observable.zip(
    Observable.from(message),
    Observable.interval(100),
    letter => letter
  ).scan((acc, curr) => acc + curr);

const Potato = props => <div>{props.message}</div>;

const AppStream = componentFromStream(props$ =>
  props$
    .switchMap(props => createTypewriter(props.message))
    .map(message => ({ message }))
    .map(Potato)
);

export default () => <AppStream message="hello world" />;

basic AJAX example using Observable.ajax, .pluck, .startWith

import React from "react";
import rxjsConfig from "recompose/rxjsObservableConfig";
import { Observable } from "rxjs";
import { setObservableConfig, componentFromStream } from "recompose";

setObservableConfig(rxjsConfig);

const pbid = id => `https://swapi.co/api/people/${id}`;

const Potato = props => (
  <div>
    <h1>{props.name}</h1>
    <h2>{props.homeworld}</h2>
  </div>
);

const AppStream = componentFromStream(props$ =>
  props$
    .switchMap(props => Observable.ajax(pbid(props.id)))
    .pluck("response")
    .switchMap(
      res =>
        Observable.ajax(res.homeworld)
          .pluck("response")
          .startWith({ name: "" }), // optional
      (person, homeworld) => ({ ...person, homeworld: homeworld.name })
    )
    .map(Potato)
);

export default () => <AppStream id={1} />;