operator/src/test/java/oracle/kubernetes/operator/PodWatcherTest.java
@SafeVarargs
  private void sendPodModifiedWatchAfterWaitForReady(Function<V1Pod,V1Pod>... modifiers) {
    AtomicBoolean stopping = new AtomicBoolean(false);
    PodWatcher watcher = createWatcher(stopping);
    testSupport.defineResources(createPod());

    try {
      testSupport.runSteps(watcher.waitForReady(createPod(), terminalStep));
      for (Function<V1Pod,V1Pod> modifier : modifiers) {
        watcher.receivedResponse(new Watch.Response<>("MODIFIED", modifier.apply(createPod())));
      }
    } finally {
      stopping.set(true);
    }
  }
// Starts the waitForReady step with an incomplete pod and sends a watch indicating that the pod has changed
Starts the waitForReady step with an incomplete pod and sends a watch indicating that the pod has changed
Starts the waitForReady step with an incomplete pod and sends a watch indicating that the pod has changed
@SafeVarargs
  private void sendPodModifiedWatchAfterWaitForReady(Function<V1Pod,V1Pod>... modifiers) {
    AtomicBoolean stopping = new AtomicBoolean(false);
    PodWatcher watcher = createWatcher(stopping);
    testSupport.defineResources(createPod());
    try {
      testSupport.runSteps(watcher.waitForReady(createPod(), terminalStep));
      for (Function<V1Pod,V1Pod> modifier : modifiers) {
        watcher.receivedResponse(new Watch.Response<>("MODIFIED", modifier.apply(createPod())));
      }
    } finally {
      stopping.set(true);
    }
  }
@ SafeVarargs private void sendPodModifiedWatchAfterWaitForReady ( Function < V1Pod , V1Pod > ... modifiers ) { AtomicBoolean stopping = new AtomicBoolean ( false ) ; PodWatcher watcher = createWatcher ( stopping ) ; testSupport . defineResources ( createPod ( ) ) ; try { testSupport . runSteps ( watcher . waitForReady ( createPod ( ) , terminalStep ) ) ; for ( Function < V1Pod , V1Pod > modifier : modifiers ) { watcher . receivedResponse ( new Watch . Response < > ( "MODIFIED" , modifier . apply ( createPod ( ) ) ) ) ; } } finally { stopping . set ( true ) ; } }
Starts the waitForReady step with an incomplete pod and sends a watch indicating that the pod has changed
Starts the waitForReady step with an incomplete pod and sends a watch indicating that the pod has changed