public ClientCall interceptCall()

in sdk-java/src/main/java/com/spotify/confidence/TelemetryClientInterceptor.java [18:33]


  public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
      MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
    return new ForwardingClientCall.SimpleForwardingClientCall<>(
        next.newCall(method, callOptions)) {
      @Override
      public void start(Listener<RespT> responseListener, Metadata headers) {
        if (telemetry != null) {
          final Monitoring telemetrySnapshot = telemetry.getSnapshot();
          final String base64Telemetry =
              Base64.getEncoder().encodeToString(telemetrySnapshot.toByteArray());
          headers.put(HEADER_KEY, base64Telemetry);
        }
        super.start(responseListener, headers);
      }
    };
  }