io.grpc.Metadata.keys()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(3.4k)|赞(0)|评价(0)|浏览(220)

本文整理了Java中io.grpc.Metadata.keys()方法的一些代码示例,展示了Metadata.keys()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Metadata.keys()方法的具体详情如下:
包路径:io.grpc.Metadata
类名称:Metadata
方法名:keys

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));

相关文章