code: private void broadcast() {
      try (LongStream events = eventStream()) {
        LongArrayList batch = new LongArrayList(batchSize);
        for (PrimitiveIterator.OfLong i = events.iterator(); i.hasNext();) {
          batch.add(i.nextLong());
          if (batch.size() == batchSize) {
            router.route(batch, self());
            batch = new LongArrayList(batchSize);
          }
        }
        router.route(batch, self());
        router.route(FINISH, self());
      } catch (Exception e) {
        context().system().log().error(e, "");
        context().stop(self());
      }
    }
docs: Broadcast the trace events to all of the policy actors.