Method addCallback

core/src/main/java/io/grpc/internal/Http2Ping.java:94–106

Registers a callback that is invoked when the ping operation completes. If this ping operation is already completed, the callback is invoked immediately. @param callback the callback to invoke @param executor the executor to use

(final ClientTransport.PingCallback callback, Executor executor)

   * @param executor the executor to use
   */
  public void addCallback(final ClientTransport.PingCallback callback, Executor executor) {
    Runnable runnable;
    synchronized (this) {
      if (!completed) {
        callbacks.put(callback, executor);
        return;
      }
      // otherwise, invoke callback immediately (but not while holding lock)
      runnable = this.failureCause != null ? asRunnable(callback, failureCause)
                                           : asRunnable(callback, roundTripTimeNanos);
    }
    doExecute(executor, runnable);
  }

  /**
   * Returns the expected ping payload for this outstanding operation.