METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_3 = 0 ; try { com . streamsets . pipeline . config . IDENT_4 IDENT_5 = com . streamsets . pipeline . config . IDENT_4 . IDENT_6 ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_7 conf = new com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . METHOD_1 ( ) ; conf . client . IDENT_8 = com . streamsets . pipeline . lib . http . IDENT_9 . IDENT_10 ; conf . client . IDENT_11 = true ; conf . client . IDENT_12 . IDENT_13 = IDENT_14 ; conf . client . IDENT_12 . IDENT_15 = ( ) -> com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_16 ; conf . client . IDENT_12 . IDENT_17 = ( ) -> com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_18 ; conf . client . IDENT_12 . IDENT_19 = ( ) -> com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_20 ; conf . client . IDENT_12 . IDENT_21 = ( ) -> com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_22 ; conf . client . IDENT_12 . IDENT_23 = ( METHOD_2 ( ) ) + STRING_0 ; conf . IDENT_24 = IDENT_25 . IDENT_26 ; conf . IDENT_27 = ( METHOD_2 ( ) ) + STRING_1 ; conf . client . IDENT_28 = 1000 ; conf . IDENT_29 . IDENT_30 = 100 ; conf . IDENT_29 . IDENT_31 = 1000 ; conf . IDENT_32 = 1000 ; conf . IDENT_33 = com . streamsets . pipeline . lib . http . IDENT_34 . IDENT_35 ; conf . IDENT_5 = IDENT_5 ; conf . IDENT_36 . IDENT_37 = com . streamsets . pipeline . config . IDENT_38 . IDENT_39 ; com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_40 IDENT_1 = new com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . METHOD_3 ( conf ) ; com . streamsets . pipeline . sdk . IDENT_41 runner = new com . streamsets . pipeline . sdk . IDENT_41 . Builder ( com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_42 . class , IDENT_1 ) . METHOD_4 ( STRING_2 ) . build ( ) ; runner . METHOD_5 ( ) ; for ( int i = 0 ; i < 3 ; i ++ ) { runner . METHOD_6 ( null , 1000 ) ; } "<AssertPlaceHolder>" ; } finally { com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . token = null ; } } METHOD_6 ( com . streamsets . pipeline . config . IDENT_43 , java . util . List ) { com . streamsets . pipeline . sdk . IDENT_44 . IDENT_45 output = runner . METHOD_6 ( null , 6 ) ; org . junit . Assert . assertTrue ( source . IDENT_46 ) ; java . util . List < com . streamsets . pipeline . api . IDENT_47 > records = METHOD_7 ( output ) ; METHOD_8 ( IDENT_5 , 0 , records ) ; output = runner . METHOD_6 ( null , INT_0 ) ; org . junit . Assert . assertTrue ( source . IDENT_46 ) ; records = METHOD_7 ( output ) ; METHOD_8 ( IDENT_5 , 6 , records ) ; output = runner . METHOD_6 ( null , 1 ) ; org . junit . Assert . assertTrue ( source . IDENT_46 ) ; records = METHOD_7 ( output ) ; METHOD_8 ( IDENT_5 , 20 , records ) ; org . junit . Assert . assertEquals ( java . lang . String . valueOf ( records ) , 0 , records . size ( ) ) ; }
org . junit . Assert . assertEquals ( 2 , com . streamsets . pipeline . IDENT_0 . IDENT_1 . http . IDENT_2 . IDENT_3 )