RxJSX

rxjsx.jsx

import { fromEvent } from "rxjs";
import { debounceTime, tap } from "rxjs/operators";

const React = {
  createElement(type, props, ...children) {
    const operator = type.call(null, props);
    if (children.length !== 0) {
      return operator.pipe(...children);
    }
    return operator;
  },
};

const FromEvent = ({ target, event }) => {
  return fromEvent(target, event);
};

const DebounceTime = ({ value }) => {
  return debounceTime(value);
};

const Tap = ({ value }) => {
  return tap(value);
};

export const blackMagicSubject = (
  <FromEvent target={document} event="click">
    <DebounceTime value={100} />
    <Tap value={console.log} />
  </FromEvent>
);

blackMagicSubject.subscribe();