METHOD_0 ( ) { org . nd4j . linalg . api . ndarray . INDArray arr = org . nd4j . linalg . factory . Nd4j . METHOD_1 ( 1.0 ) ; final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_2 ( true ) ; io . IDENT_2 . IDENT_3 IDENT_2 = io . IDENT_2 . IDENT_3 . connect ( METHOD_3 ( ) ) ; org . nd4j . IDENT_2 . IDENT_4 . IDENT_5 IDENT_6 = org . nd4j . IDENT_2 . IDENT_4 . IDENT_5 . builder ( ) . METHOD_4 ( METHOD_4 ) . METHOD_5 ( METHOD_5 ) . channel ( channel ) . METHOD_6 ( METHOD_6 ) . METHOD_7 ( new org . nd4j . METHOD_5 . IDENT_4 . METHOD_8 ( ) { @ org . nd4j . METHOD_5 . IDENT_4 . Override public void METHOD_9 ( org . nd4j . METHOD_5 . IDENT_4 . IDENT_7 message ) { System . out . println ( arr ) ; METHOD_6 . set ( false ) ; } @ org . nd4j . METHOD_5 . IDENT_4 . Override public void METHOD_10 ( org . nd4j . linalg . api . ndarray . INDArray arr , long IDENT_8 , int OP_0 IDENT_9 ) { } @ org . nd4j . METHOD_5 . IDENT_4 . Override public void METHOD_11 ( org . nd4j . linalg . api . ndarray . INDArray arr ) { } } ) . build ( ) ; java . lang . Thread t = new java . lang . Thread ( ( ) -> { try { IDENT_6 . METHOD_12 ( ) ; } catch ( e ) { org . nd4j . METHOD_5 . IDENT_4 . e . printStackTrace ( ) ; } } ) ; t . start ( ) ; while ( ! ( IDENT_6 . METHOD_13 ( ) ) ) java . lang . Thread . sleep ( 1000 ) ; java . lang . Thread . sleep ( INT_0 ) ; org . nd4j . METHOD_5 . IDENT_4 . IDENT_10 IDENT_11 = org . nd4j . METHOD_5 . IDENT_4 . IDENT_10 . builder ( ) . METHOD_4 ( METHOD_4 ) . METHOD_5 ( METHOD_5 ) . channel ( channel ) . build ( ) ; for ( int i = 0 ; ( i < 1 ) && ( METHOD_6 . get ( ) ) ; i ++ ) { IDENT_11 . METHOD_14 ( arr ) ; } java . lang . Thread . sleep ( INT_1 ) ; "<AssertPlaceHolder>" ; IDENT_11 . close ( ) ; IDENT_6 . close ( ) ; } get ( ) { try { IDENT_12 . METHOD_15 ( ) . METHOD_16 ( ) ; return value ; } finally { METHOD_16 . METHOD_15 ( ) . METHOD_17 ( ) ; } }
org . junit . Assert . assertFalse ( METHOD_6 . get ( ) )