@Test public void resolvers_WhenProtocolIsSocket_ShouldReturnZipkinSocketRequestUuidResolver() { Protocol protocol = Protocol.SOCKET; DehydratedExecutionContextResolver[] result = victim.resolvers(protocol); assertArrayEquals(new DehydratedExecutionContextResolver[]{socketRequestResolver}, result); }
@Override public <T, B> DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol) { if (protocol.underlyingTransportIsHttp() && httpRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ httpRequestResolver }; } if (protocol == Protocol.SOCKET && socketRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ socketRequestResolver }; } return null; }
ZipkinExecutionContextResolverFactory implements DehydratedExecutionContextResolverFactory { @Override public <T, B> DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol) { if (protocol.underlyingTransportIsHttp() && httpRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ httpRequestResolver }; } if (protocol == Protocol.SOCKET && socketRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ socketRequestResolver }; } return null; } }
ZipkinExecutionContextResolverFactory implements DehydratedExecutionContextResolverFactory { @Override public <T, B> DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol) { if (protocol.underlyingTransportIsHttp() && httpRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ httpRequestResolver }; } if (protocol == Protocol.SOCKET && socketRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ socketRequestResolver }; } return null; }  }
ZipkinExecutionContextResolverFactory implements DehydratedExecutionContextResolverFactory { @Override public <T, B> DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol) { if (protocol.underlyingTransportIsHttp() && httpRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ httpRequestResolver }; } if (protocol == Protocol.SOCKET && socketRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ socketRequestResolver }; } return null; }  void setHttpRequestResolver(DehydratedExecutionContextResolver httpRequestResolver); void setSocketRequestResolver(DehydratedExecutionContextResolver socketRequestResolver); @Override DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol); @Override String getName(); }
ZipkinExecutionContextResolverFactory implements DehydratedExecutionContextResolverFactory { @Override public <T, B> DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol) { if (protocol.underlyingTransportIsHttp() && httpRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ httpRequestResolver }; } if (protocol == Protocol.SOCKET && socketRequestResolver != null) { return new DehydratedExecutionContextResolver[]{ socketRequestResolver }; } return null; }  void setHttpRequestResolver(DehydratedExecutionContextResolver httpRequestResolver); void setSocketRequestResolver(DehydratedExecutionContextResolver socketRequestResolver); @Override DehydratedExecutionContextResolver<T, B>[] resolvers(Protocol protocol); @Override String getName();  }