docs: public static AeronNDArrayResponder startSubscriber(Aeron aeron, String host, int port, NDArrayHolder callback,
                      int streamId) {
  
          if (callback == null)
              throw new IllegalArgumentException("NDArrayHolder must be specified");
  
          final AtomicBoolean running = new AtomicBoolean(true);
  
  
          AeronNDArrayResponder subscriber = AeronNDArrayResponder.builder().streamId(streamId).aeron(aeron)
                          .channel(AeronUtil.aeronChannel(host, port)).running(running).ndArrayHolder(callback).build();
  
  
          Thread t = new Thread(() -> {
              try {
                  subscriber.launch();
              } catch (Exception e) {
                  e.printStackTrace();
              }
  
          });
  
          t.start();
  
          return subscriber;
      }