private synchronized void sendCurrentConfig ( CurrentLibraryConfig currentLibraryConfig ) { if ( isCompleted ( ) || currentConfigObserver == null ) { return ; } try { currentConfigObserver . onNext ( currentLibraryConfig ) ; } catch ( Exception e ) { // Catch client side exceptions. onComplete ( e ) ; } }
Sends current config to Agent if the stream is still connected otherwise do nothing .