### Question:
JobWatcher extends Watcher<V1Job> implements WatchListener<V1Job> { public Step waitForReady(V1Job job, Step next) { return new WaitForJobReadyStep(job, next); } private  JobWatcher(
      String namespace,
      String initialResourceVersion,
      WatchTuning tuning,
      AtomicBoolean isStopping); static @Nonnull JobWatcher getOrCreateFor(Domain domain); @Override String getNamespace(); static JobWatcher create(
      ThreadFactory factory,
      String ns,
      String initialResourceVersion,
      WatchTuning tuning,
      AtomicBoolean isStopping); static boolean isComplete(V1Job job); @Override WatchI<V1Job> initiateWatch(WatchBuilder watchBuilder); void receivedResponse(Watch.Response<V1Job> item); Step waitForReady(V1Job job, Step next);  }### Answer:
@Test public void waitForReady_returnsAStep() { JobWatcher watcher = createWatcher(new AtomicBoolean(true)); assertThat(watcher.waitForReady(cachedJob, null), instanceOf(Step.class)); }