METHOD_0 ( ) { java . io . IOException test = new java . io . IOException ( "test" ) ; org . apache . nifi . IDENT_0 . IDENT_1 . IDENT_2 IDENT_3 = new org . apache . nifi . IDENT_0 . IDENT_1 . METHOD_1 ( STRING_0 . getBytes ( IDENT_4 . UTF_8 ) ) . METHOD_2 ( STRING_1 , "value" ) ; IDENT_5 . METHOD_3 ( data , java . util . Arrays . stream ( new org . apache . nifi . IDENT_0 . IDENT_1 . METHOD_1 [ ] { IDENT_3 } ) . collect ( java . util . stream . IDENT_6 . toList ( ) ) ) ; METHOD_4 ( test ) . when ( transaction ) . METHOD_5 ( any ( org . apache . nifi . remote . protocol . IDENT_7 . class ) ) ; try { IDENT_8 . get ( ) . METHOD_6 ( ) ; } catch ( java . io . IOException e ) { "<AssertPlaceHolder>" ; throw e ; } } METHOD_6 ( ) { org . apache . nifi . remote . IDENT_9 transaction = IDENT_10 . METHOD_7 ( IDENT_11 . IDENT_12 ) ; try { org . apache . nifi . IDENT_0 . IDENT_1 . METHOD_1 . METHOD_8 ( input ) . METHOD_9 ( ( d ) -> { try { transaction . METHOD_5 ( d ) ; } catch ( e ) { throw new < org . apache . nifi . IDENT_0 . IDENT_1 . e > java . lang . RuntimeException ( ) ; } } ) ; } catch ( java . lang . RuntimeException e ) { java . lang . Throwable IDENT_13 = e . METHOD_10 ( ) ; if ( IDENT_13 instanceof java . io . IOException ) { throw ( ( java . io . IOException ) ( IDENT_13 ) ) ; } throw new java . io . IOException ( e . getMessage ( ) , e ) ; } transaction . METHOD_11 ( ) ; return transaction . METHOD_12 ( ) ; }
org . junit . Assert . assertEquals ( test , e )