private void forwardToParameterServer ( INDArrayMessage message ) { try { incomingFlow . accept ( message ) ; } catch ( Exception e ) { throw new RuntimeException ( e ) ; } }
This method puts INDArray to the flow read by parameter server