Skip to content

Commit c9963bd

Browse files
committed
feat(reorganize): add rxjs/create exports
BREAKING CHANGE: All create functions such as `of`, `from`, `combineLatest` and `fromEvent` should now be imported from `rxjs/create`.
1 parent b1f8bfe commit c9963bd

File tree

3 files changed

+56
-27
lines changed

3 files changed

+56
-27
lines changed

spec/create/index-spec.ts

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
import * as index from '../../src/create/index';
2+
import { expect } from 'chai';
3+
4+
describe('index', () => {
5+
it('should export static observable creator functions', () => {
6+
expect(index.bindCallback).to.exist;
7+
expect(index.bindNodeCallback).to.exist;
8+
expect(index.combineLatest).to.exist;
9+
expect(index.concat).to.exist;
10+
expect(index.defer).to.exist;
11+
expect(index.empty).to.exist;
12+
expect(index.forkJoin).to.exist;
13+
expect(index.from).to.exist;
14+
expect(index.fromEvent).to.exist;
15+
expect(index.fromEventPattern).to.exist;
16+
expect(index.generate).to.exist;
17+
expect(index.iif).to.exist;
18+
expect(index.interval).to.exist;
19+
expect(index.merge).to.exist;
20+
expect(index.never).to.exist;
21+
expect(index.of).to.exist;
22+
expect(index.onErrorResumeNext).to.exist;
23+
expect(index.pairs).to.exist;
24+
expect(index.race).to.exist;
25+
expect(index.range).to.exist;
26+
expect(index.throwError).to.exist;
27+
expect(index.timer).to.exist;
28+
expect(index.using).to.exist;
29+
expect(index.zip).to.exist;
30+
});
31+
});

spec/index-spec.ts

Lines changed: 0 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -2,33 +2,6 @@ import * as index from '../src/index';
22
import { expect } from 'chai';
33

44
describe('index', () => {
5-
it('should export static observable creator functions', () => {
6-
expect(index.bindCallback).to.exist;
7-
expect(index.bindNodeCallback).to.exist;
8-
expect(index.combineLatest).to.exist;
9-
expect(index.concat).to.exist;
10-
expect(index.defer).to.exist;
11-
expect(index.empty).to.exist;
12-
expect(index.forkJoin).to.exist;
13-
expect(index.from).to.exist;
14-
expect(index.fromEvent).to.exist;
15-
expect(index.fromEventPattern).to.exist;
16-
expect(index.generate).to.exist;
17-
expect(index.iif).to.exist;
18-
expect(index.interval).to.exist;
19-
expect(index.merge).to.exist;
20-
expect(index.never).to.exist;
21-
expect(index.of).to.exist;
22-
expect(index.onErrorResumeNext).to.exist;
23-
expect(index.pairs).to.exist;
24-
expect(index.race).to.exist;
25-
expect(index.range).to.exist;
26-
expect(index.throwError).to.exist;
27-
expect(index.timer).to.exist;
28-
expect(index.using).to.exist;
29-
expect(index.zip).to.exist;
30-
});
31-
325
it('should export the Subject types', () => {
336
expect(index.Subject).to.exist;
347
expect(index.BehaviorSubject).to.exist;

src/create/index.ts

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
/* Static observable creation exports */
2+
export { bindCallback } from '../internal/observable/bindCallback';
3+
export { bindNodeCallback } from '../internal/observable/bindNodeCallback';
4+
export { combineLatest } from '../internal/observable/combineLatest';
5+
export { concat } from '../internal/observable/concat';
6+
export { defer } from '../internal/observable/defer';
7+
export { empty } from '../internal/observable/empty';
8+
export { forkJoin } from '../internal/observable/forkJoin';
9+
export { from } from '../internal/observable/from';
10+
export { fromEvent } from '../internal/observable/fromEvent';
11+
export { fromEventPattern } from '../internal/observable/fromEventPattern';
12+
export { generate } from '../internal/observable/generate';
13+
export { _if as iif } from '../internal/observable/if';
14+
export { interval } from '../internal/observable/interval';
15+
export { merge } from '../internal/observable/merge';
16+
export { never } from '../internal/observable/never';
17+
export { of } from '../internal/observable/of';
18+
export { onErrorResumeNext } from '../internal/observable/onErrorResumeNext';
19+
export { pairs } from '../internal/observable/pairs';
20+
export { race } from '../internal/observable/race';
21+
export { range } from '../internal/observable/range';
22+
export { _throw as throwError } from '../internal/observable/throw';
23+
export { timer } from '../internal/observable/timer';
24+
export { using } from '../internal/observable/using';
25+
export { zip } from '../internal/observable/zip';

0 commit comments

Comments
 (0)