docs: @Override
      public void onNDArrayPartial(INDArray arr, long idx, int... dimensions) {
          try (AeronNDArrayPublisher publisher = AeronNDArrayPublisher.builder().streamId(streamId).ctx(aeronContext)
                          .channel(masterUrl).build()) {
              publisher.publish(NDArrayMessage.builder().arr(arr).dimensions(dimensions).index(idx).build());
              log.debug("NDArray PublishingListener publishing to channel " + masterUrl + ":" + streamId);
          } catch (Exception e) {
              throw new RuntimeException(e);
          }
      }