METHOD_0 ( ) { org . apache . nifi . IDENT_0 . IDENT_1 IDENT_2 = session . create ( ) ; IDENT_2 = session . append ( IDENT_2 , new org . apache . nifi . processor . io . METHOD_1 ( ) { @ org . apache . nifi . controller . repository . Override public void process ( java . io . IDENT_3 out ) throws java . io . IOException { out . write ( STRING_0 . getBytes ( ) ) ; } } ) ; IDENT_4 . IDENT_5 = true ; IDENT_2 = session . append ( IDENT_2 , new org . apache . nifi . processor . io . METHOD_1 ( ) { @ org . apache . nifi . controller . repository . Override public void process ( java . io . IDENT_3 out ) throws java . io . IOException { out . write ( STRING_1 . getBytes ( ) ) ; } } ) ; IDENT_2 = session . append ( IDENT_2 , new org . apache . nifi . processor . io . METHOD_1 ( ) { @ org . apache . nifi . controller . repository . Override public void process ( java . io . IDENT_3 out ) throws java . io . IOException { out . write ( STRING_2 . getBytes ( ) ) ; } } ) ; IDENT_4 . IDENT_5 = false ; final byte [ ] IDENT_6 = new byte [ STRING_3 . getBytes ( ) . length ] ; session . read ( IDENT_2 , new org . apache . nifi . processor . io . METHOD_2 ( ) { @ org . apache . nifi . controller . repository . Override public void process ( final java . io . InputStream in ) throws java . io . IOException { org . apache . nifi . stream . io . IDENT_7 . METHOD_3 ( in , IDENT_6 ) ; } } ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( java . io . InputStream , byte [ ] ) { org . apache . nifi . stream . io . IDENT_7 . METHOD_3 ( source , IDENT_8 , true ) ; }
org . junit . Assert . assertEquals ( STRING_3 , new java . lang . String ( IDENT_6 ) )