METHOD_0 ( ) { com . IDENT_0 . streaming . common . IDENT_1 < com . IDENT_0 . streaming . event . IDENT_2 [ ] [ ] , com . IDENT_0 . streaming . event . IDENT_2 [ ] [ ] > IDENT_3 = com . IDENT_0 . streaming . process . join . IDENT_4 . METHOD_1 ( IDENT_5 . IDENT_6 , IDENT_5 . IDENT_7 ) ; com . IDENT_0 . streaming . common . IDENT_1 < com . IDENT_0 . streaming . event . IDENT_2 [ ] [ ] , com . IDENT_0 . streaming . event . IDENT_2 [ ] [ ] > IDENT_8 = com . IDENT_0 . streaming . process . join . IDENT_4 . METHOD_1 ( IDENT_5 . IDENT_7 , IDENT_5 . IDENT_9 ) ; IDENT_10 . METHOD_2 ( IDENT_3 . METHOD_3 ( ) , IDENT_3 . METHOD_4 ( ) ) ; IDENT_10 . METHOD_2 ( IDENT_8 . METHOD_3 ( ) , IDENT_8 . METHOD_4 ( ) ) ; IDENT_11 [ 0 ] [ 0 ] = com . IDENT_0 . streaming . process . join . IDENT_4 . METHOD_5 ( IDENT_5 . IDENT_9 ) ; result = IDENT_10 . join ( IDENT_11 , null ) ; java . util . Set < com . IDENT_0 . streaming . common . IDENT_12 > IDENT_13 = new java . util . IDENT_14 < com . IDENT_0 . streaming . common . IDENT_12 > ( ) ; java . lang . Object [ ] obj = new java . lang . Object [ com . IDENT_0 . streaming . support . IDENT_5 . IDENT_6 ] ; obj [ 0 ] = IDENT_11 [ 0 ] [ 0 ] ; obj [ 1 ] = IDENT_8 . METHOD_3 ( ) [ 1 ] [ 0 ] ; IDENT_13 . add ( new com . IDENT_0 . streaming . common . METHOD_6 ( obj ) ) ; "<AssertPlaceHolder>" ; } size ( ) { return IDENT_15 ; }
org . junit . Assert . assertArrayEquals ( IDENT_13 . toArray ( new com . IDENT_0 . streaming . common . METHOD_6 [ IDENT_13 . size ( ) ] ) , result . METHOD_3 ( ) . toArray ( new com . IDENT_0 . streaming . common . METHOD_6 [ result . METHOD_3 ( ) . size ( ) ] ) )