private void broadcastVertexConnectedComponentChange()

in java/connected-components/src/main/java/org/apache/flink/statefun/playground/java/connectedcomponents/ConnectedComponentsFn.java [120:125]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  private void broadcastVertexConnectedComponentChange(
      Context context, int source, Iterable<Integer> neighbours, int componentId) {
    for (Integer neighbour : neighbours) {
      sendVertexConnectedComponentChange(context, source, neighbour, componentId);
    }
  }