joystream/pioneer/packages/react-api/test/observable.js

/* eslint-disable @typescript-eslint/no-var-requires */
// Copyright 2017-2019 @polkadot/react-query authors & contributors
// This software may be modified and distributed under the terms
// of the Apache-2.0 license. See the LICENSE file for details.

const createObservable = require('@polkadot/api-rx/observable');

module.exports = function observable (method) {
  const fn = () => Promise.resolve(12345);

  fn.unsubscribe = () => Promise.resolve(true);

  return createObservable(`section_${method}`, method, {
    [method]: fn
  })();
};