com.thomsonreuters.upa.codec.Buffer.toString()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(142)

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

Buffer.toString介绍

[英]Converts the underlying buffer into a String. This should only be called when the Buffer is known to contain ASCII data. This method creates garbage unless the underlying buffer is a String.
[中]将基础缓冲区转换为字符串。仅当已知缓冲区包含ASCII数据时,才应调用此函数。除非基础缓冲区是字符串,否则此方法将创建垃圾。

代码示例

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String string()
{
  if (_rsslBuffer.length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslBuffer.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String string()
{
  if (_rsslBuffer.length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslBuffer.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String name()
{
  return ((_rsslDictionaryEntry == null) ? DataImpl.EMPTY_STRING : (_rsslDictionaryEntry.acronym().toString()));
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String string()
{
  if (_rsslBuffer.length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslBuffer.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String string()
{
  if (_rsslBuffer.length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslBuffer.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String ascii()
{
  if (_rsslBuffer.length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslBuffer.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

private static String xmlDumpBuffer(Buffer buffer)
{
  String ret = "";
  if (buffer.length() > 0)
    ret = buffer.toString();
  return ret;
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String toString()
{
  StringBuilder strBuf = new StringBuilder("State: " + StreamStates.info(_streamState) + "/" +
                       DataStates.info(_dataState) + "/" +
                       StateCodes.info(_code) + " - text: ");
  strBuf.append("\"" + _text.toString() + "\"");
  return strBuf.toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String name()
{
  if (_rsslElementEntry.name().length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslElementEntry.name().toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

private void processGenericConsumerRequest(Channel channel, GenericMsg genericMsg)
{
  // create thread to send file response
  SendFileResponseThread sendFileResponseThread = new SendFileResponseThread(channel, genericMsg.msgKey().name().toString(), genericMsg.streamId(), genericMsg.domainType(), _providerSession);
  Executors.newSingleThreadExecutor().execute(sendFileResponseThread);
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String statusText()
{
  if (_rsslState.text().length() == 0)
    return DataImpl.EMPTY_STRING;
  else
    return _rsslState.text().toString();
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String meaning() {
  return rsslEnumType.meaning().data() != null ? rsslEnumType.meaning().toString() : "";
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String enumRecordTemplateVersion() {
  return rsslDataDictionary.infoEnumRTVersion().data() != null ?  rsslDataDictionary.infoEnumRTVersion().toString() : "";
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String fieldDescription() {
  return rsslDataDictionary.infoFieldDesc().data() != null ? rsslDataDictionary.infoFieldDesc().toString() : "";
}

代码示例来源:origin: Refinitiv/Elektron-SDK

@Override
public String enumDate() {
  return rsslDataDictionary.infoEnumDate().data() != null ? rsslDataDictionary.infoEnumDate().toString() : "";
}

代码示例来源:origin: Refinitiv/Elektron-SDK

void addToMap(Service service)
{
  if (service.checkHasInfo())
  {
    addToMap(service.serviceId(),service.info().serviceName().toString());
  }
}

代码示例来源:origin: Refinitiv/Elektron-SDK

String serviceName(int serviceId)
{
  String serviceName = null;
  
  WlService wlService = service(serviceId);
  
  if (wlService != null && wlService.rdmService().checkHasInfo())
  {
    serviceName = wlService.rdmService().info().serviceName().toString();
  }
  
  return serviceName;
}

代码示例来源:origin: Refinitiv/Elektron-SDK

private void verifyServiceData(Service.ServiceData rdmServiceData, Service.ServiceData rdmServiceData2)
{
  assertEquals(rdmServiceData.flags(), rdmServiceData2.flags());
  assertEquals(rdmServiceData.type(), rdmServiceData2.type());
  if (rdmServiceData.checkHasData())
  {
    assertEquals(rdmServiceData.dataType(), rdmServiceData2.dataType());
    assertEquals(rdmServiceData.data().toString(), rdmServiceData2.data().toString());
  }
}

代码示例来源:origin: Refinitiv/Elektron-SDK

private void verifyDictionaryRequest(DictionaryRequest dictionaryRequest, int streamId, String name)
{
  assertEquals(DictionaryMsgType.REQUEST, dictionaryRequest.rdmMsgType());
  assertEquals(true, dictionaryRequest.checkStreaming());
  assertEquals(Dictionary.VerbosityValues.NORMAL, dictionaryRequest.verbosity());
  assertEquals(streamId, dictionaryRequest.streamId());
  assertTrue(dictionaryRequest.dictionaryName().toString().equals(name));		
}

代码示例来源:origin: Refinitiv/Elektron-SDK

private void verifyDirectoryRefresh(DirectoryRefresh directoryRefresh, int streamId, String serviceName)
  {
    assertEquals(DirectoryMsgType.REFRESH, directoryRefresh.rdmMsgType());
    assertEquals(true, directoryRefresh.checkClearCache());
    assertEquals(false, directoryRefresh.checkSolicited());
    assertEquals(NIProviderRole.FILTER_TO_REFRESH, directoryRefresh.filter());
    assertEquals(streamId, directoryRefresh.streamId());
    assertEquals(1, directoryRefresh.serviceList().size());
    assertTrue(directoryRefresh.serviceList().get(0).info().serviceName().toString().equals(serviceName));
  }
}

相关文章