METHOD_0 ( ) { java . io . File IDENT_0 = METHOD_1 ( ) ; com . IDENT_1 . IDENT_2 . pipeline . IDENT_3 < java . lang . String > IDENT_4 = com . IDENT_1 . IDENT_2 . pipeline . IDENT_5 . batch ( STRING_0 , ( ctx ) -> METHOD_2 ( IDENT_0 ) ) . < java . lang . String > METHOD_3 ( ( in , buf ) -> { java . lang . String line = in . METHOD_4 ( ) ; if ( line != null ) { buf . add ( line ) ; } else { buf . close ( ) ; } } ) . METHOD_5 ( IDENT_6 :: close ) . METHOD_6 ( com . IDENT_1 . IDENT_2 . pipeline . IDENT_7 . IDENT_8 ) . build ( ) ; com . IDENT_1 . IDENT_2 . pipeline . IDENT_9 p = com . IDENT_1 . IDENT_2 . pipeline . IDENT_9 . create ( ) ; p . METHOD_7 ( IDENT_4 ) . METHOD_8 ( METHOD_9 ( ) ) ; METHOD_10 ( ) . METHOD_11 ( p ) . join ( ) ; java . util . Map < java . lang . String , java . lang . Integer > actual = METHOD_12 ( ) ; java . util . Map < java . lang . String , java . lang . Integer > expected = java . util . stream . IDENT_10 . range ( 0 , IDENT_11 ) . METHOD_13 ( ) . collect ( java . util . stream . IDENT_12 . METHOD_14 ( ( i ) -> STRING_1 + i , ( i ) -> ( com . IDENT_1 . METHOD_10 . pipeline . IDENT_7 . IDENT_8 ) * com . IDENT_1 . METHOD_10 . pipeline . IDENT_13 ) ) ; "<AssertPlaceHolder>" ; } METHOD_14 ( com . IDENT_1 . METHOD_10 . function . IDENT_14 , com . IDENT_1 . METHOD_10 . function . IDENT_14 ) { METHOD_15 ( IDENT_15 , STRING_2 ) ; METHOD_15 ( IDENT_16 , STRING_3 ) ; return com . IDENT_1 . METHOD_10 . IDENT_17 . IDENT_18 . METHOD_14 ( IDENT_15 , IDENT_16 , ( k , v ) -> { throw new java . lang . IllegalStateException ( ( STRING_4 + k ) ) ; } , HashMap :: new ) ; }
org . junit . Assert . assertEquals ( expected , actual )