METHOD_0 ( ) { try ( io . IDENT_0 . streaming . IDENT_1 IDENT_2 = new io . IDENT_0 . streaming . METHOD_1 ( io . IDENT_0 . streaming . IDENT_3 . IDENT_4 , false ) ) { io . IDENT_0 . streaming . IDENT_5 options = new io . IDENT_0 . streaming . IDENT_5 . Builder ( ) . METHOD_2 ( IDENT_2 . METHOD_3 ( ) ) . build ( ) ; try ( io . IDENT_0 . streaming . IDENT_6 IDENT_7 = io . IDENT_0 . streaming . IDENT_8 . connect ( io . IDENT_0 . streaming . IDENT_3 . IDENT_4 , io . IDENT_0 . streaming . IDENT_3 . IDENT_9 , options ) ) { int IDENT_10 = 1000 ; java . util . List < io . IDENT_0 . streaming . IDENT_11 > IDENT_12 = new java . util . concurrent . METHOD_4 ( ) ; for ( int i = 0 ; i < IDENT_10 ; i ++ ) { io . IDENT_0 . streaming . IDENT_11 IDENT_13 = null ; try { IDENT_13 = IDENT_7 . METHOD_5 ( "foo" , null ) ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } IDENT_12 . add ( IDENT_13 ) ; } "<AssertPlaceHolder>" ; for ( io . IDENT_0 . streaming . IDENT_11 IDENT_13 : IDENT_12 ) { try { IDENT_13 . METHOD_6 ( ) ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } } } } } METHOD_5 ( java . lang . String , io . IDENT_0 . streaming . io . IDENT_0 . streaming . IDENT_14 ) { return METHOD_5 ( subject , cb , null ) ; }
org . junit . Assert . assertEquals ( IDENT_10 , IDENT_12 . size ( ) )