docs: public synchronized void shutdown() {
          if (stopLock.get())
              return;
  
  
          // shutting down underlying transport
          transport.shutdown();
  
          // disposing INDArray flow
          disposable.dispose();
  
          updaterParamsSubscribers.clear();
          modelParamsSubsribers.clear();
          updatesSubscribers.clear();
          updatesQueue.clear();
  
          // state that we're done
          launchLock.set(false);
  
          stopLock.set(true);
      }