code: void awaitResponses() {
          try {
              boolean finishedNicely = responseFinished.await(WAIT_TIMEOUT_MILISECONDS, TimeUnit.MILLISECONDS);
              if (!finishedNicely) {
                  throw new WarpSynchronizationException(WarpContextStore.get());
              }
          } catch (InterruptedException e) {
          }
      }
docs: Await responses for requests or premature finishing