14
14
import javax .annotation .Nullable ;
15
15
16
16
/**
17
- * FlagdGrpcInterceptor is an interceptor for grpc communication from java-sdk to flagd
18
- * <p>
19
- * <a href="https://github.com/open-telemetry/opentelemetry-java-docs">credits</a>
17
+ * FlagdGrpcInterceptor is an interceptor for grpc communication from java-sdk to flagd.
18
+ * <a href="https://github.com/open-telemetry/opentelemetry-java-docs">credits</a>
20
19
*/
21
20
final class FlagdGrpcInterceptor implements ClientInterceptor {
22
21
private static final TextMapSetter <Metadata > SETTER = new Setter ();
@@ -27,30 +26,24 @@ final class FlagdGrpcInterceptor implements ClientInterceptor {
27
26
this .openTelemetry = openTelemetry ;
28
27
}
29
28
30
- @ Override
31
- public <ReqT , RespT > ClientCall <ReqT , RespT > interceptCall (
32
- MethodDescriptor <ReqT , RespT > methodDescriptor , CallOptions callOptions , Channel channel ) {
29
+ @ Override public <ReqT , RespT > ClientCall <ReqT , RespT > interceptCall (MethodDescriptor <ReqT , RespT > methodDescriptor ,
30
+ CallOptions callOptions , Channel channel ) {
33
31
34
32
final ClientCall <ReqT , RespT > call = channel .newCall (methodDescriptor , callOptions );
35
33
36
34
return new ForwardingClientCall .SimpleForwardingClientCall <ReqT , RespT >(call ) {
37
- @ Override
38
- public void start (Listener <RespT > responseListener , io .grpc .Metadata headers ) {
39
- openTelemetry .getPropagators ()
40
- .getTextMapPropagator ()
41
- .inject (Context .current (), headers , SETTER );
42
-
35
+ @ Override public void start (Listener <RespT > responseListener , io .grpc .Metadata headers ) {
36
+ openTelemetry .getPropagators ().getTextMapPropagator ().inject (Context .current (), headers , SETTER );
43
37
super .start (responseListener , headers );
44
38
}
45
39
};
46
40
}
47
41
48
42
/**
49
- * Setter implements TextMapSetter with carrier check
43
+ * Setter implements TextMapSetter with carrier check.
50
44
*/
51
45
static class Setter implements TextMapSetter <Metadata > {
52
- @ Override
53
- public void set (@ Nullable Metadata carrier , String key , String value ) {
46
+ @ Override public void set (@ Nullable Metadata carrier , String key , String value ) {
54
47
if (carrier == null ) {
55
48
return ;
56
49
}
0 commit comments