METHOD_0 ( ) { when ( IDENT_0 . METHOD_1 ( ) ) . thenReturn ( org . apache . IDENT_1 . types . avro . IDENT_2 . METHOD_2 ( ) ) ; doReturn ( IDENT_3 ) . when ( pipeline ) . METHOD_3 ( org . apache . IDENT_1 . types . avro . IDENT_2 . METHOD_2 ( ) ) ; when ( IDENT_0 . METHOD_4 ( ) ) . thenReturn ( null ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( org . apache . IDENT_1 . IDENT_4 ) { org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_6 < T > impl = METHOD_6 ( IDENT_0 ) ; if ( impl instanceof org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_7 ) { org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_7 < T > IDENT_8 = ( ( org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_7 < T > ) ( impl ) ) ; if ( ( IDENT_8 . METHOD_7 ( ) ) instanceof org . apache . IDENT_1 . io . IDENT_9 ) { return ( ( org . apache . IDENT_1 . io . IDENT_9 ) ( IDENT_8 . METHOD_7 ( ) ) ) ; } else { throw new java . lang . IllegalArgumentException ( ( STRING_0 + IDENT_8 ) ) ; } } else if ( impl instanceof org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_10 ) { org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_10 it = ( ( org . apache . IDENT_1 . impl . IDENT_5 . collect . IDENT_10 ) ( impl ) ) ; if ( ( it . METHOD_7 ( ) ) instanceof org . apache . IDENT_1 . io . IDENT_9 ) { return ( ( org . apache . IDENT_1 . io . IDENT_9 ) ( it . METHOD_7 ( ) ) ) ; } else { throw new java . lang . IllegalArgumentException ( ( STRING_1 + it ) ) ; } } org . apache . IDENT_1 . IDENT_11 < ? > IDENT_12 = impl . METHOD_4 ( ) ; if ( ( IDENT_12 != null ) && ( IDENT_12 instanceof org . apache . IDENT_1 . io . IDENT_13 ) ) { return ( ( org . apache . IDENT_1 . io . IDENT_13 < T > ) ( IDENT_12 ) ) ; } org . apache . IDENT_1 . io . IDENT_13 < T > IDENT_14 = null ; if ( IDENT_15 . containsKey ( IDENT_0 ) ) { for ( org . apache . IDENT_1 . IDENT_16 target : IDENT_15 . get ( impl ) ) { if ( ( target instanceof org . apache . IDENT_1 . io . IDENT_13 ) && ( ! ( IDENT_17 . contains ( target ) ) ) ) { return ( ( org . apache . IDENT_1 . io . IDENT_13 < T > ) ( target ) ) ; } } } org . apache . IDENT_1 . IDENT_11 < T > IDENT_18 = METHOD_3 ( IDENT_0 . METHOD_1 ( ) ) ; if ( ! ( IDENT_18 instanceof org . apache . IDENT_1 . io . IDENT_13 ) ) { throw new java . lang . IllegalArgumentException ( ( STRING_2 + STRING_3 ) ) ; } else { IDENT_14 = ( ( org . apache . IDENT_1 . io . IDENT_13 < T > ) ( IDENT_18 ) ) ; METHOD_8 ( impl , IDENT_14 ) ; return IDENT_14 ; } }
org . junit . Assert . assertEquals ( IDENT_3 , pipeline . METHOD_5 ( IDENT_0 ) )