docs: public static AeronNDArraySubscriber startSubscriber(Aeron.Context context, String host, int port,
                      NDArrayCallback callback, int streamId, AtomicBoolean running) {
  
          AeronNDArraySubscriber subscriber = AeronNDArraySubscriber.builder().streamId(streamId).ctx(context)
                          .channel(AeronUtil.aeronChannel(host, port)).running(running).ndArrayCallback(callback).build();
  
  
          Thread t = new Thread(() -> {
              try {
                  subscriber.launch();
              } catch (Exception e) {
                  e.printStackTrace();
              }
  
          });
  
          t.start();
  
  
          return subscriber;
      }