METHOD_0 ( ) { int IDENT_0 = 0 ; IDENT_1 = new org . apache . beam . sdk . io . IDENT_2 . METHOD_1 ( IDENT_0 , IDENT_3 . IDENT_4 ) ; IDENT_5 . IDENT_6 < org . apache . beam . sdk . values . IDENT_7 < byte [ ] , byte [ ] > > reader = source . METHOD_2 ( pipeline . METHOD_3 ( ) , IDENT_1 ) ; reader . start ( ) ; org . apache . beam . sdk . values . IDENT_7 < byte [ ] , byte [ ] > IDENT_8 = reader . METHOD_4 ( ) ; org . apache . beam . sdk . values . IDENT_7 < byte [ ] , byte [ ] > IDENT_9 = IDENT_3 . METHOD_5 ( ( IDENT_0 + 1 ) ) . IDENT_10 ; "<AssertPlaceHolder>" ; } METHOD_5 ( long ) { long IDENT_11 = METHOD_6 ( ) . METHOD_7 ( position ) . METHOD_8 ( ) ; return new org . apache . beam . sdk . io . IDENT_2 . IDENT_12 . METHOD_9 ( METHOD_10 ( IDENT_11 ) , METHOD_11 ( IDENT_11 ) ) ; }
org . junit . Assert . assertEquals ( IDENT_9 , IDENT_8 )