diff --git a/packages/rpc-core/src/util/refCountDelay.ts b/packages/rpc-core/src/util/refCountDelay.ts index 15281c3b87..721855a28f 100644 --- a/packages/rpc-core/src/util/refCountDelay.ts +++ b/packages/rpc-core/src/util/refCountDelay.ts @@ -1,7 +1,9 @@ // Copyright 2017-2020 @polkadot/rpc-core authors & contributors // SPDX-License-Identifier: Apache-2.0 -import { asapScheduler, ConnectableObservable, MonoTypeOperatorFunction, Observable, Subscription, TeardownLogic } from '@polkadot/x-rxjs'; +import type { ConnectableObservable, MonoTypeOperatorFunction, TeardownLogic } from '@polkadot/x-rxjs'; + +import { asapScheduler, Observable, Subscription } from '@polkadot/x-rxjs'; /** @internal */ export function refCountDelay (delay = 1750): MonoTypeOperatorFunction { diff --git a/packages/x-rxjs/.skip-esm b/packages/x-rxjs/.skip-esm deleted file mode 100644 index e69de29bb2..0000000000 diff --git a/packages/x-rxjs/src/index.ts b/packages/x-rxjs/src/index.d.ts similarity index 100% rename from packages/x-rxjs/src/index.ts rename to packages/x-rxjs/src/index.d.ts diff --git a/packages/x-rxjs/src/index.js b/packages/x-rxjs/src/index.js new file mode 100644 index 0000000000..d5a90adcef --- /dev/null +++ b/packages/x-rxjs/src/index.js @@ -0,0 +1,71 @@ +// Copyright 2017-2020 @polkadot/x-rxjs authors & contributors +// SPDX-License-Identifier: Apache-2.0 + +// This is not great, but while having esm files, rxjs doesn't quite play nicely with +// Node.js mjs files. (Hopefully this improves in 7.0, although no exports map as of yet) +// +// Generated via s/export \{ (.*) \} from .*/exports.$1 = rxjs.$1;/ on rxjs/_esm + +const rxjs = require('rxjs'); + +exports.Observable = rxjs.Observable; +exports.ConnectableObservable = rxjs.ConnectableObservable; +exports.GroupedObservable = rxjs.GroupedObservable; +exports.observable = rxjs.observable; +exports.Subject = rxjs.Subject; +exports.BehaviorSubject = rxjs.BehaviorSubject; +exports.ReplaySubject = rxjs.ReplaySubject; +exports.AsyncSubject = rxjs.AsyncSubject; +exports.asap = rxjs.asap; +exports.asapScheduler = rxjs.asapScheduler; +exports.async = rxjs.async; +exports.asyncScheduler = rxjs.asyncScheduler; +exports.queue = rxjs.queue; +exports.queueScheduler = rxjs.queueScheduler; +exports.animationFrame = rxjs.animationFrame; +exports.animationFrameScheduler = rxjs.animationFrameScheduler; +exports.VirtualTimeScheduler = rxjs.VirtualTimeScheduler; +exports.VirtualAction = rxjs.VirtualAction; +exports.Scheduler = rxjs.Scheduler; +exports.Subscription = rxjs.Subscription; +exports.Subscriber = rxjs.Subscriber; +exports.Notification = rxjs.Notification; +exports.NotificationKind = rxjs.NotificationKind; +exports.pipe = rxjs.pipe; +exports.noop = rxjs.noop; +exports.identity = rxjs.identity; +exports.isObservable = rxjs.isObservable; +exports.ArgumentOutOfRangeError = rxjs.ArgumentOutOfRangeError; +exports.EmptyError = rxjs.EmptyError; +exports.ObjectUnsubscribedError = rxjs.ObjectUnsubscribedError; +exports.UnsubscriptionError = rxjs.UnsubscriptionError; +exports.TimeoutError = rxjs.TimeoutError; +exports.bindCallback = rxjs.bindCallback; +exports.bindNodeCallback = rxjs.bindNodeCallback; +exports.combineLatest = rxjs.combineLatest; +exports.concat = rxjs.concat; +exports.defer = rxjs.defer; +exports.empty = rxjs.empty; +exports.forkJoin = rxjs.forkJoin; +exports.from = rxjs.from; +exports.fromEvent = rxjs.fromEvent; +exports.fromEventPattern = rxjs.fromEventPattern; +exports.generate = rxjs.generate; +exports.iif = rxjs.iif; +exports.interval = rxjs.interval; +exports.merge = rxjs.merge; +exports.never = rxjs.never; +exports.of = rxjs.of; +exports.onErrorResumeNext = rxjs.onErrorResumeNext; +exports.pairs = rxjs.pairs; +exports.partition = rxjs.partition; +exports.race = rxjs.race; +exports.range = rxjs.range; +exports.throwError = rxjs.throwError; +exports.timer = rxjs.timer; +exports.using = rxjs.using; +exports.zip = rxjs.zip; +exports.scheduled = rxjs.scheduled; +exports.EMPTY = rxjs.EMPTY; +exports.NEVER = rxjs.NEVER; +exports.config = rxjs.config; diff --git a/packages/x-rxjs/src/operators.ts b/packages/x-rxjs/src/operators.d.ts similarity index 100% rename from packages/x-rxjs/src/operators.ts rename to packages/x-rxjs/src/operators.d.ts diff --git a/packages/x-rxjs/src/operators.js b/packages/x-rxjs/src/operators.js new file mode 100644 index 0000000000..615dca9d27 --- /dev/null +++ b/packages/x-rxjs/src/operators.js @@ -0,0 +1,114 @@ +// Copyright 2017-2020 @polkadot/x-rxjs authors & contributors +// SPDX-License-Identifier: Apache-2.0 + +// This is not great, but while having esm files, rxjs doesn't quite play nicely with +// Node.js mjs files. (Hopefully this improves in 7.0, although no exports map as of yet) +// +// Generated via s/export \{ (.*) \} from .*/exports.$1 = rxjs.$1;/ on rxjs/_esm + +const operators = require('rxjs/operators'); + +exports.audit = operators.audit; +exports.auditTime = operators.auditTime; +exports.buffer = operators.buffer; +exports.bufferCount = operators.bufferCount; +exports.bufferTime = operators.bufferTime; +exports.bufferToggle = operators.bufferToggle; +exports.bufferWhen = operators.bufferWhen; +exports.catchError = operators.catchError; +exports.combineAll = operators.combineAll; +exports.combineLatest = operators.combineLatest; +exports.concat = operators.concat; +exports.concatAll = operators.concatAll; +exports.concatMap = operators.concatMap; +exports.concatMapTo = operators.concatMapTo; +exports.count = operators.count; +exports.debounce = operators.debounce; +exports.debounceTime = operators.debounceTime; +exports.defaultIfEmpty = operators.defaultIfEmpty; +exports.delay = operators.delay; +exports.delayWhen = operators.delayWhen; +exports.dematerialize = operators.dematerialize; +exports.distinct = operators.distinct; +exports.distinctUntilChanged = operators.distinctUntilChanged; +exports.distinctUntilKeyChanged = operators.distinctUntilKeyChanged; +exports.elementAt = operators.elementAt; +exports.endWith = operators.endWith; +exports.every = operators.every; +exports.exhaust = operators.exhaust; +exports.exhaustMap = operators.exhaustMap; +exports.expand = operators.expand; +exports.filter = operators.filter; +exports.finalize = operators.finalize; +exports.find = operators.find; +exports.findIndex = operators.findIndex; +exports.first = operators.first; +exports.groupBy = operators.groupBy; +exports.ignoreElements = operators.ignoreElements; +exports.isEmpty = operators.isEmpty; +exports.last = operators.last; +exports.map = operators.map; +exports.mapTo = operators.mapTo; +exports.materialize = operators.materialize; +exports.max = operators.max; +exports.merge = operators.merge; +exports.mergeAll = operators.mergeAll; +exports.mergeMap = operators.mergeMap; +exports.flatMap = operators.flatMap; +exports.mergeMapTo = operators.mergeMapTo; +exports.mergeScan = operators.mergeScan; +exports.min = operators.min; +exports.multicast = operators.multicast; +exports.observeOn = operators.observeOn; +exports.onErrorResumeNext = operators.onErrorResumeNext; +exports.pairwise = operators.pairwise; +exports.partition = operators.partition; +exports.pluck = operators.pluck; +exports.publish = operators.publish; +exports.publishBehavior = operators.publishBehavior; +exports.publishLast = operators.publishLast; +exports.publishReplay = operators.publishReplay; +exports.race = operators.race; +exports.reduce = operators.reduce; +exports.repeat = operators.repeat; +exports.repeatWhen = operators.repeatWhen; +exports.retry = operators.retry; +exports.retryWhen = operators.retryWhen; +exports.refCount = operators.refCount; +exports.sample = operators.sample; +exports.sampleTime = operators.sampleTime; +exports.scan = operators.scan; +exports.sequenceEqual = operators.sequenceEqual; +exports.share = operators.share; +exports.shareReplay = operators.shareReplay; +exports.single = operators.single; +exports.skip = operators.skip; +exports.skipLast = operators.skipLast; +exports.skipUntil = operators.skipUntil; +exports.skipWhile = operators.skipWhile; +exports.startWith = operators.startWith; +exports.subscribeOn = operators.subscribeOn; +exports.switchAll = operators.switchAll; +exports.switchMap = operators.switchMap; +exports.switchMapTo = operators.switchMapTo; +exports.take = operators.take; +exports.takeLast = operators.takeLast; +exports.takeUntil = operators.takeUntil; +exports.takeWhile = operators.takeWhile; +exports.tap = operators.tap; +exports.throttle = operators.throttle; +exports.throttleTime = operators.throttleTime; +exports.throwIfEmpty = operators.throwIfEmpty; +exports.timeInterval = operators.timeInterval; +exports.timeout = operators.timeout; +exports.timeoutWith = operators.timeoutWith; +exports.timestamp = operators.timestamp; +exports.toArray = operators.toArray; +exports.window = operators.window; +exports.windowCount = operators.windowCount; +exports.windowTime = operators.windowTime; +exports.windowToggle = operators.windowToggle; +exports.windowWhen = operators.windowWhen; +exports.withLatestFrom = operators.withLatestFrom; +exports.zip = operators.zip; +exports.zipAll = operators.zipAll;