Skip to content

Commit c42845c

Browse files
committed
feat(index): export utility functions
1 parent cc7865a commit c42845c

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

src/index.ts

+8-1
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,13 @@
11
import { Observable } from 'rxjs/Observable';
2+
import { SubscriptionLog } from 'rxjs/testing/SubscriptionLog';
3+
import { parseObservableMarble } from './marbles/parseObservableMarble';
4+
import { parseSubscriptionMarble } from './marbles/parseSubscriptionMarble';
25
import { TestMessage } from './message/TestMessage';
36
import { TestScheduler } from './scheduler/TestScheduler';
47

58
//workaround TS4029 by explicitly import types and avoid unused import error
69
(() => Observable.toString())();
10+
(() => SubscriptionLog.toString())();
711

812
const rxSandbox = {
913
create: (autoFlush: boolean = false, frameTimeFactor: number = 1) => {
@@ -15,7 +19,10 @@ const rxSandbox = {
1519
flush: scheduler.flush.bind(scheduler) as typeof scheduler.flush,
1620
advanceBy: scheduler.advanceBy.bind(scheduler) as typeof scheduler.advanceBy,
1721
advanceTo: scheduler.advanceTo.bind(scheduler) as typeof scheduler.advanceTo,
18-
getMarbles: scheduler.getMarbles.bind(scheduler) as typeof scheduler.getMarbles
22+
getMarbles: scheduler.getMarbles.bind(scheduler) as typeof scheduler.getMarbles,
23+
e: <T = string>(marble: string, value?: { [key: string]: T } | null, error?: any) =>
24+
parseObservableMarble(marble, value, error, true, frameTimeFactor),
25+
s: (marble: string) => parseSubscriptionMarble(marble, frameTimeFactor)
1926
};
2027
}
2128
};

src/marbles/parseObservableMarble.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ const parseObservableMarble = <T>(
1818
error?: any,
1919
materializeInnerObservables: boolean = false,
2020
frameTimeFactor = 1
21-
): Array<TestMessage<T | Array<TestMessage<T>>>> => {
21+
): Readonly<Array<TestMessage<T | Array<TestMessage<T>>>>> => {
2222
if (marble.indexOf(SubscriptionMarbleToken.UNSUBSCRIBE) !== -1) {
2323
throw new Error(`Observable marble cannot have unsubscription marker ${SubscriptionMarbleToken.UNSUBSCRIBE}`);
2424
}

0 commit comments

Comments
 (0)