METHOD_0 ( ) { java . util . concurrent . IDENT_0 < org . apache . streams . core . IDENT_1 > out = new java . util . concurrent . METHOD_1 ( ) ; org . apache . streams . IDENT_2 . IDENT_3 . IDENT_4 task = new org . apache . streams . IDENT_2 . IDENT_3 . METHOD_2 ( IDENT_5 , true , null ) ; when ( IDENT_5 . METHOD_3 ( ) ) . thenReturn ( true ) ; when ( IDENT_5 . METHOD_4 ( ) ) . thenReturn ( new org . apache . streams . core . METHOD_5 ( METHOD_6 ( 3 ) ) ) ; task . METHOD_7 ( 100 ) ; task . METHOD_8 ( 10 ) ; task . METHOD_9 ( ) . add ( out ) ; task . run ( ) ; "<AssertPlaceHolder>" ; } size ( ) { return queue . size ( ) ; }
org . junit . Assert . assertThat ( out . size ( ) , org . hamcrest . CoreMatchers . is ( org . hamcrest . CoreMatchers . equalTo ( 3 ) ) )