File tree 1 file changed +5
-3
lines changed 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -27,7 +27,8 @@ const traverseInstructions = {
27
27
source . pipe (
28
28
concatMap ( value => value ) ,
29
29
traverse ( transforms )
30
- )
30
+ ) ,
31
+ [ undefined ] : ( ) => source => source
31
32
} ;
32
33
33
34
export const serialize = ( asyncTransforms , syncTransforms ) => source =>
@@ -52,12 +53,13 @@ export const parse = syncTransforms => source =>
52
53
53
54
const traverse = transforms => source =>
54
55
source . pipe (
55
- mergeMap ( data => of ( data ) . pipe ( getOperator ( data ) ( transforms ) ) ) ,
56
+ mergeMap ( data => of ( data ) . pipe ( traverseInstructions [ getInstructionKey ( data ) ] ( transforms ) ) ) ,
56
57
transform ( transforms )
57
58
//
58
59
) ;
59
60
60
- const getOperator = data => traverseInstructions [ data . constructor ] || ( ( ) => source => source ) ;
61
+ const getInstructionKey = ( { constructor } ) =>
62
+ constructor in traverseInstructions ? constructor : undefined ;
61
63
62
64
const transform = transforms => source =>
63
65
source . pipe ( concatMap ( data => of ( data ) . pipe ( findTransform ( transforms , data ) . handler ( ) ) ) ) ;
You can’t perform that action at this time.
0 commit comments