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

    try {
      testSupport.runSteps(watcher.waitForReady(createPod(), terminalStep));
      for (Function<V1Pod,V1Pod> modifier : modifiers) {
        modifier.apply(pod);
      }
    } finally {
      stopping.set(true);
    }
  }
// Simulates a pod that is ready but where Kubernetes has failed to send the watch event
Simulates a pod that is ready but where Kubernetes has failed to send the watch event
Simulates a pod that is ready but where Kubernetes has failed to send the watch event
@SafeVarargs
  private void makeModifiedPodReadyWithNoWatchEvent(Function<V1Pod,V1Pod>... modifiers) {
    AtomicBoolean stopping = new AtomicBoolean(false);
    PodWatcher watcher = createWatcher(stopping);
    V1Pod pod = createPod();
    testSupport.defineResources(pod);
    try {
      testSupport.runSteps(watcher.waitForReady(createPod(), terminalStep));
      for (Function<V1Pod,V1Pod> modifier : modifiers) {
        modifier.apply(pod);
      }
    } finally {
      stopping.set(true);
    }
  }
@ SafeVarargs private void makeModifiedPodReadyWithNoWatchEvent ( Function < V1Pod , V1Pod > ... modifiers ) { AtomicBoolean stopping = new AtomicBoolean ( false ) ; PodWatcher watcher = createWatcher ( stopping ) ; V1Pod pod = createPod ( ) ; testSupport . defineResources ( pod ) ; try { testSupport . runSteps ( watcher . waitForReady ( createPod ( ) , terminalStep ) ) ; for ( Function < V1Pod , V1Pod > modifier : modifiers ) { modifier . apply ( pod ) ; } } finally { stopping . set ( true ) ; } }
Simulates a pod that is ready but where Kubernetes has failed to send the watch event
Simulates a pod that is ready but where Kubernetes has failed to send the watch event