METHOD_0 ( ) { com . streamsets . pipeline . api . IDENT_0 IDENT_1 = com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_3 . METHOD_1 ( IDENT_4 , com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_3 . IDENT_5 ) ; long IDENT_6 = java . nio . file . IDENT_7 . size ( java . nio . file . IDENT_8 . get ( com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_9 . METHOD_2 ( IDENT_4 ) ) ) ; long IDENT_10 = IDENT_6 ; try ( java . io . InputStream is = org . mockito . Mockito . METHOD_3 ( IDENT_1 . METHOD_4 ( context , java . io . InputStream . class ) ) ) { java . util . concurrent . atomic . IDENT_11 IDENT_12 = new java . util . concurrent . atomic . METHOD_5 ( ( - 1 ) ) ; java . util . concurrent . atomic . IDENT_13 IDENT_14 = new java . util . concurrent . atomic . METHOD_6 ( false ) ; METHOD_7 ( is , IDENT_12 , IDENT_14 ) ; "<AssertPlaceHolder>" ; while ( ( is . read ( ) ) != ( - 1 ) ) { IDENT_10 OP_0 ; METHOD_8 ( is , IDENT_10 , 1 , IDENT_12 , IDENT_14 ) ; IDENT_12 . set ( ( - 1 ) ) ; IDENT_14 . set ( false ) ; } } } METHOD_9 ( T extends com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_15 ) { return ( ( long ) ( org . mockito . internal . util . IDENT_16 . IDENT_17 . METHOD_10 ( stream , STRING_0 ) ) ) ; }
org . junit . Assert . assertEquals ( IDENT_6 , com . streamsets . pipeline . lib . io . IDENT_2 . IDENT_3 . METHOD_9 ( is ) )