本文整理了Java中io.grpc.Metadata.keys()
方法的一些代码示例,展示了Metadata.keys()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Metadata.keys()
方法的具体详情如下:
包路径:io.grpc.Metadata
类名称:Metadata
方法名:keys
[英]Returns set of all keys in store.
[中]返回存储区中所有密钥的集合。
代码示例来源:origin: googleapis/google-cloud-java
private String getResourceHeaderValue(
SpannerMetadataProvider headerProvider, String resourceTokenTemplate) {
Metadata metadata = headerProvider.newMetadata(resourceTokenTemplate, "projects/p");
assertEquals(1, metadata.keys().size());
return metadata.get(Key.of("header3", Metadata.ASCII_STRING_MARSHALLER));
}
}
代码示例来源:origin: weibocom/motan
private DefaultRequest getBaseMotanRequest(Metadata headers) {
DefaultRequest request = new DefaultRequest();
request.setMethodName(methodName);
request.setParamtersDesc(paramsDesc);
request.setInterfaceName(provider.getInterface().getName());
String rid = headers.get(REQUEST_ID);
if (rid == null) {
rid = headers.get(Metadata.Key.of(URLParamType.requestIdFromClient.getName().toLowerCase(), Metadata.ASCII_STRING_MARSHALLER));
}
if (rid != null) {
request.setAttachment(URLParamType.requestIdFromClient.getName(), rid);
}
// fill attachment info from headers
Set<String> keys = headers.keys();
for (String key : keys) {
String value = headers.get(Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER));
if (value != null) {
request.setAttachment(key, value);
}
}
return request;
}
代码示例来源:origin: googleapis/google-cloud-java
@Test
public void testGetHeadersAsMetadata() {
Map<String, String> headers = ImmutableMap.of("header1", "value1", "header2", "value2");
SpannerMetadataProvider metadataProvider = SpannerMetadataProvider.create(headers, "header3");
Metadata metadata = metadataProvider.newMetadata(null, "stuff");
assertEquals(headers.size() + 1, metadata.keys().size());
assertEquals(
headers.get("header1"), metadata.get(Key.of("header1", Metadata.ASCII_STRING_MARSHALLER)));
assertEquals(
headers.get("header2"), metadata.get(Key.of("header2", Metadata.ASCII_STRING_MARSHALLER)));
assertEquals("stuff", metadata.get(Key.of("header3", Metadata.ASCII_STRING_MARSHALLER)));
}
代码示例来源:origin: salesforce/grpc-java-contrib
/**
* Returns set of all keys in store.
*
* @return unmodifiable Set of keys
*/
public Set<String> keys() {
return contextMetadata.keys();
}
代码示例来源:origin: com.salesforce.servicelibs/grpc-contrib
/**
* Returns set of all keys in store.
*
* @return unmodifiable Set of keys
*/
public Set<String> keys() {
return contextMetadata.keys();
}
代码示例来源:origin: com.payneteasy.grpc-long-polling/grpc-long-polling-server
@Override
public void writeHeaders(Metadata headers) {
LOG.trace("writeHeaders({})", headers);
for (String key : headers.keys()) {
response.addHeader(key, headers.get(Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER)));
}
}
代码示例来源:origin: com.salesforce.servicelibs/grpc-contrib
for (String keyName : headers.keys()) {
if (!keyName.startsWith(headerPrefix)) {
continue;
代码示例来源:origin: salesforce/grpc-java-contrib
for (String keyName : headers.keys()) {
if (!keyName.startsWith(headerPrefix)) {
continue;
代码示例来源:origin: sitewhere/sitewhere
ServerCallHandler<ReqT, RespT> next) {
Map<String, String> headerMap = new HashMap<String, String>();
for (String key : headers.keys()) {
if (!key.endsWith(Metadata.BINARY_HEADER_SUFFIX)) {
String value = headers.get(Metadata.Key.of(key, Metadata.ASCII_STRING_MARSHALLER));
内容来源于网络,如有侵权,请联系作者删除!