Method interceptCall

binder/src/main/java/io/grpc/binder/PeerUids.java:87–98

(
          ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next)

  public static ServerInterceptor newPeerIdentifyingServerInterceptor() {
    return new ServerInterceptor() {
      @Override
      public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
          ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) {
        Context context = Context.current();
        PeerUid client =
            new PeerUid(
                checkNotNull(
                    call.getAttributes().get(BinderTransport.REMOTE_UID),
                    "Expected BinderTransport attribute REMOTE_UID was missing. Is this "
                        + "interceptor installed on an unsupported type of Server?"));
        return Contexts.interceptCall(context.withValue(REMOTE_PEER, client), call, headers, next);
      }
    };
  }