METHOD_0 ( ) { final java . util . List < org . apache . kafka . common . serialization . IDENT_0 < io . IDENT_1 . IDENT_2 . IDENT_3 > > IDENT_4 = new java . util . METHOD_1 ( ) ; final io . IDENT_1 . IDENT_2 . IDENT_5 . IDENT_6 . IDENT_7 serializer = new io . IDENT_1 . IDENT_2 . IDENT_5 . IDENT_6 . METHOD_2 ( ( ) -> { final IDENT_0 < io . IDENT_1 . IDENT_2 . IDENT_3 > IDENT_8 = mock ( . class ) ; IDENT_4 . add ( IDENT_8 ) ; expect ( IDENT_8 . METHOD_3 ( anyString ( ) , METHOD_4 ( . class ) ) ) . andReturn ( new io . IDENT_1 . IDENT_2 . METHOD_5 ( java . util . Collections . emptyList ( ) ) ) . times ( 1 ) ; replay ( IDENT_8 ) ; return IDENT_4 . get ( ( ( IDENT_4 . size ( ) ) - 1 ) ) ; } ) ; for ( int i = 0 ; i < 3 ; i ++ ) { final java . lang . Thread t = new java . lang . Thread ( ( ) -> serializer . METHOD_3 ( "foo" , new byte [ INT_0 ] ) ) ; t . start ( ) ; t . join ( ) ; "<AssertPlaceHolder>" ; IDENT_4 . METHOD_6 ( EasyMock :: verify ) ; } } size ( ) { return size ; }
org . junit . Assert . assertThat ( IDENT_4 . size ( ) , org . hamcrest . CoreMatchers . equalTo ( ( i + 1 ) ) )