src/index.js

import Channel from './channel';
import Rxmq from './rxmq';

export { EndlessSubject, EndlessReplaySubject } from './rx/index';
export { Channel };
export default Rxmq;