code: 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;
      }
docs: Start a subscriber in another thread
  based on the given parameters
  @param context the context to use
  @param host the host opName to bind to
  @param port the port to bind to
  @param callback the call back to use for the subscriber
  @param streamId the stream id to subscribe to
  @return the subscriber reference