We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 43a8503 commit 579c679Copy full SHA for 579c679
src/marbles/parseObservableMarble.ts
@@ -0,0 +1,21 @@
1
+import { TestMessage } from '../message/TestMessage';
2
+import { SubscriptionMarbleToken } from './SubscriptionMarbleToken';
3
+
4
+const parseObservableMarble = <T>(
5
+ marble: string,
6
+ _value?: { [key: string]: T },
7
+ _error?: any,
8
+ _materializeInnerObservables: boolean = false
9
+): Array<TestMessage<T>> => {
10
+ if (marble.indexOf(SubscriptionMarbleToken.UNSUBSCRIBE) !== -1) {
11
+ throw new Error(`Observable marble cannot have unsubscription marker ${SubscriptionMarbleToken.UNSUBSCRIBE}`);
12
+ }
13
14
+ const messages = Array.from(marble).reduce((acc: Array<any>, _value: string) => {
15
+ return acc;
16
+ }, []);
17
18
+ return messages;
19
+};
20
21
+export { parseObservableMarble };
0 commit comments