METHOD_0 ( ) { try ( final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_3 queue = builder ( METHOD_1 ( ) , IDENT_4 ) . build ( ) ) { final java . lang . String expected = STRING_0 ; net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_5 IDENT_6 = net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_7 . METHOD_2 ( ) ; net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_8 IDENT_9 = null ; try { net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_10 f = IDENT_6 . METHOD_3 ( ( ) -> { final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_11 IDENT_12 = queue . METHOD_4 ( ) ; try ( final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_13 dc = IDENT_12 . METHOD_5 ( ) ) { dc . METHOD_6 ( ) . METHOD_7 ( ( ) -> STRING_1 ) . text ( expected ) ; } } ) ; net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_14 < net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_15 > result = new net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . METHOD_8 ( 10 ) ; IDENT_9 = net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_7 . METHOD_9 ( ) ; IDENT_9 . METHOD_10 ( ( ) -> { net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_15 b = net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_15 . METHOD_11 ( INT_0 ) ; final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_16 IDENT_17 = queue . METHOD_12 ( ) ; IDENT_17 . METHOD_13 ( b ) ; if ( ( b . METHOD_14 ( ) ) == 0 ) return ; b . METHOD_15 ( 0 ) ; result . add ( b ) ; throw new net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . METHOD_16 ( ) ; } , 1 , 1 , TimeUnit . IDENT_18 ) ; final net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_15 bytes = result . METHOD_17 ( 5 , TimeUnit . IDENT_19 ) ; if ( bytes == null ) { f . get ( 1 , TimeUnit . IDENT_19 ) ; throw new java . lang . METHOD_18 ( STRING_2 ) ; } try { final java . lang . String actual = this . IDENT_4 . apply ( bytes ) . read ( ( ) -> STRING_1 ) . text ( ) ; "<AssertPlaceHolder>" ; f . get ( 1 , TimeUnit . IDENT_19 ) ; } finally { bytes . METHOD_19 ( ) ; } } finally { IDENT_6 . METHOD_20 ( ) ; if ( IDENT_9 != null ) IDENT_9 . METHOD_20 ( ) ; } } } read ( net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_16 ) { try ( final net . IDENT_0 . IDENT_1 . METHOD_6 . IDENT_13 dc = IDENT_17 . METHOD_21 ( ) ) { if ( ! ( dc . METHOD_22 ( ) ) ) { return null ; } final java . io . IDENT_20 in = dc . METHOD_6 ( ) . METHOD_23 ( ) ; return new net . IDENT_0 . IDENT_1 . queue . impl . IDENT_2 . IDENT_21 . METHOD_24 ( in . METHOD_25 ( ) ) ; } }
org . junit . Assert . assertEquals ( expected , actual )