public class org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor extends java.lang.Object implements org.apache.dubbo.rpc.protocol.grpc.interceptors.ClientInterceptor, org.apache.dubbo.rpc.protocol.grpc.interceptors.ServerInterceptor
{
private static final java.lang.String DUBBO;
public void <init>()
{
org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor v;
v := @this: org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public io.grpc.ClientCall interceptCall(io.grpc.MethodDescriptor, io.grpc.CallOptions, io.grpc.Channel)
{
io.grpc.CallOptions v;
org.apache.dubbo.rpc.RpcContext v;
java.util.HashMap v;
io.grpc.Channel v;
io.grpc.ClientCall v;
java.util.Map v;
org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$1 v;
io.grpc.MethodDescriptor v;
org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor v;
v := @this: org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor;
v := @parameter: io.grpc.MethodDescriptor;
v := @parameter: io.grpc.CallOptions;
v := @parameter: io.grpc.Channel;
v = staticinvoke <org.apache.dubbo.rpc.RpcContext: org.apache.dubbo.rpc.RpcContext getContext()>();
v = new java.util.HashMap;
v = virtualinvoke v.<org.apache.dubbo.rpc.RpcContext: java.util.Map getObjectAttachments()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = new org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$1;
v = virtualinvoke v.<io.grpc.Channel: io.grpc.ClientCall newCall(io.grpc.MethodDescriptor,io.grpc.CallOptions)>(v, v);
specialinvoke v.<org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$1: void <init>(org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor,io.grpc.ClientCall,java.util.Map)>(v, v, v);
return v;
}
public io.grpc.ServerCall$Listener interceptCall(io.grpc.ServerCall, io.grpc.Metadata, io.grpc.ServerCallHandler)
{
io.grpc.ServerCallHandler v;
java.util.function.Predicate v;
io.grpc.ServerCall$Listener v;
java.util.Set v;
java.util.HashMap v;
java.util.function.Consumer v;
java.util.stream.Stream v, v;
org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$2 v;
io.grpc.ServerCall v;
io.grpc.Metadata v;
org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor v;
v := @this: org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor;
v := @parameter: io.grpc.ServerCall;
v := @parameter: io.grpc.Metadata;
v := @parameter: io.grpc.ServerCallHandler;
v = virtualinvoke v.<io.grpc.Metadata: java.util.Set keys()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
if v == null goto label;
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$lambda_interceptCall_0__10: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$lambda_interceptCall_1__11: java.util.function.Consumer bootstrap$(java.util.Map,io.grpc.Metadata)>(v, v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
label:
v = new org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$2;
v = interfaceinvoke v.<io.grpc.ServerCallHandler: io.grpc.ServerCall$Listener startCall(io.grpc.ServerCall,io.grpc.Metadata)>(v, v);
specialinvoke v.<org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor$2: void <init>(org.apache.dubbo.rpc.protocol.grpc.interceptors.RpcContextInterceptor,io.grpc.ServerCall$Listener,io.grpc.ServerCall,java.util.Map)>(v, v, v, v);
return v;
}
}