$_invoke$4 method

dynamic $_invoke$4(dynamic xform$3, dynamic error_xform$2, dynamic error_mode$1, dynamic x$4,)

Implementation

dc.dynamic $_invoke$4(dc.dynamic xform$3, dc.dynamic error_xform$2, dc.dynamic error_mode$1, dc.dynamic x$4, ){
return (dc.Stream.eventTransformed((lcoc_core.stream.$_invoke$1(x$4, )), (dc.dynamic es$1, ){
final lcoc_core.streamReify18695hm$1 f$1=lcoc_core.streamReify18695hm$1(null, es$1, );
final lcoc_core.streamReify18695hm$1 add_rf$1=f$1;
late final dc.dynamic rf$1;
if((xform$3 is dc.Function)){
rf$1=(xform$3 as dc.Function)(add_rf$1, );
}else if((xform$3 is lcoc_core.IFn$iface)){
rf$1=((xform$3 as lcoc_core.IFn$iface).$_invoke$1(add_rf$1, ));
}else{
rf$1=(lcoc_core.IFn.extensions(xform$3, ).$_invoke$1(xform$3, add_rf$1, ));
}
final dc.dynamic o7835$1=error_mode$1;
late final dc.int hash$1;
if((o7835$1 is lcoc_core.IHash$iface)){
hash$1=(((o7835$1 as lcoc_core.IHash$iface).$_hash$0()) as dc.int);
}else{
hash$1=(((lcoc_core.IHash.extensions(o7835$1, ) as lcoc_core.IHash$ext).$_hash$0(o7835$1, )) as dc.int);
}
late final dc.dynamic $case_$1;
switch(hash$1){
case 2891327769:
if((lcoc_core.$EQ_.$_invoke$2(const lcoc_core.Keyword(null, "as-values", 2891327769, ), error_mode$1, ))){
$case_$1=add_rf$1;
}else{
continue _default;
}
break;
case 2859597282:
if((lcoc_core.$EQ_.$_invoke$2(const lcoc_core.Keyword(null, "as-errors", 2859597282, ), error_mode$1, ))){
final lcoc_core.streamReify18695hm$2 f$2=lcoc_core.streamReify18695hm$2(null, es$1, );
$case_$1=f$2;
}else{
continue _default;
}
break;
_default: default:
throw dc.ArgumentError((lcoc_core.str.$_invoke$2("No matching clause: ", (lcoc_core.pr_str.$_invoke$1(error_mode$1, )), )), );
}
late final dc.dynamic error_rf$1;
if((error_xform$2 is dc.Function)){
error_rf$1=(error_xform$2 as dc.Function)($case_$1, );
}else if((error_xform$2 is lcoc_core.IFn$iface)){
error_rf$1=((error_xform$2 as lcoc_core.IFn$iface).$_invoke$1($case_$1, ));
}else{
error_rf$1=(lcoc_core.IFn.extensions(error_xform$2, ).$_invoke$1(error_xform$2, $case_$1, ));
}
return lcoc_core.streamReify5ehc0s$1(null, es$1, rf$1, error_rf$1, );
}, ));
}