METHOD_0 ( ) { io . IDENT_0 . stream . IDENT_1 < java . lang . Integer > source = io . IDENT_0 . stream . IDENT_1 . of ( 3 , 1 , 3 , 2 , 5 , 1 , 4 , 3 , 2 ) ; java . util . concurrent . IDENT_2 executor = java . util . concurrent . IDENT_3 . METHOD_1 ( ) ; io . IDENT_0 . stream . processor . IDENT_4 < java . lang . Integer > storage = io . IDENT_0 . stream . processor . IDENT_5 . create ( executor , io . IDENT_0 . stream . processor . IDENT_6 , IDENT_7 . METHOD_2 ( ) . METHOD_3 ( ) ) ; io . IDENT_0 . stream . processor . IDENT_8 < java . lang . Integer , java . lang . Integer > IDENT_9 = io . IDENT_0 . stream . processor . IDENT_8 . create ( storage , java . util . function . IDENT_10 . METHOD_4 ( ) , Integer :: compareTo , true , 2 ) ; java . util . List < java . lang . Integer > list = new java . util . ArrayList ( ) ; io . IDENT_0 . stream . IDENT_11 < java . lang . Integer > consumer = io . IDENT_0 . stream . IDENT_11 . create ( list ) ; io . IDENT_0 . exception . IDENT_12 exception = new io . IDENT_0 . exception . METHOD_5 ( ) ; java . lang . Throwable e = METHOD_6 ( source . METHOD_7 ( IDENT_9 . METHOD_8 ( ) ) , IDENT_9 . METHOD_9 ( ) . METHOD_7 ( consumer . METHOD_10 ( METHOD_11 ( ( context , IDENT_13 ) -> ( item ) -> { IDENT_13 . accept ( item ) ; if ( ( list . size ( ) ) == 2 ) { context . METHOD_12 ( exception ) ; } } ) ) ) ) ; "<AssertPlaceHolder>" ; } METHOD_12 ( java . lang . Throwable ) { IDENT_14 . METHOD_13 ( e ) ; }
org . junit . Assert . assertSame ( exception , e )