com.thomsonreuters.upa.shared.rdm.yieldcurve.YieldCurveRequest.checkPrivateStream()方法的使用及代码示例

x33g5p2x  于2022-02-05 转载在 其他  
字(3.0k)|赞(0)|评价(0)|浏览(98)

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

YieldCurveRequest.checkPrivateStream介绍

[英]Checks the presence of private stream flag.
[中]检查是否存在私有流标志。

代码示例

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

private int sendBatchRequest(ChannelSession chnl, List<String> itemNames, Error error)
{
  int batchStreamId = watchList.add(domainType, "BATCH_" + new Date(),
      yieldCurveRequest.checkPrivateStream());
  yieldCurveRequest.streamId(batchStreamId);
  for (String itemName : itemNames)
  {
    watchList.add(domainType, itemName,    yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().add(itemName);
  }
  return encodeAndSendRequest(chnl, yieldCurveRequest, error);
}

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

private int sendBatchRequest(ReactorChannel chnl, List<String> itemNames, ReactorErrorInfo errorInfo)
{
  int batchStreamId = watchList.add(domainType, "BATCH_" + new Date(),
      yieldCurveRequest.checkPrivateStream());
  yieldCurveRequest.streamId(batchStreamId);
  for (String itemName : itemNames)
  {
    watchList.add(domainType, itemName,    yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().add(itemName);
  }
  return encodeAndSendRequest(chnl, yieldCurveRequest, errorInfo);
}

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

private int sendRequest(ChannelSession chnl, List<String> itemNames, Error error)
{
  int ret = CodecReturnCodes.SUCCESS;
  for (String itemName : itemNames)
  {
    Integer streamId = watchList.add(domainType, itemName, yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().clear();
    yieldCurveRequest.itemNames().add(itemName);
    yieldCurveRequest.streamId(streamId);
    ret = encodeAndSendRequest(chnl, yieldCurveRequest, error);
    if (ret < CodecReturnCodes.SUCCESS)
      return ret;
  }
  return CodecReturnCodes.SUCCESS;
}

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

stringBuf.append(checkPrivateStream());
stringBuf.append(eolChar);

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

private int sendRequest(ReactorChannel chnl, List<String> itemNames, ReactorErrorInfo errorInfo)
{
  int ret = CodecReturnCodes.SUCCESS;
  for (String itemName : itemNames)
  {
    Integer streamId = watchList.add(domainType, itemName, yieldCurveRequest.checkPrivateStream());
    yieldCurveRequest.itemNames().clear();
    yieldCurveRequest.itemNames().add(itemName);
    yieldCurveRequest.streamId(streamId);
    ret = encodeAndSendRequest(chnl, yieldCurveRequest, errorInfo);
    if (ret < CodecReturnCodes.SUCCESS)
      return ret;
  }
  return CodecReturnCodes.SUCCESS;
}

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

private void applyFeatureFlags(boolean isBatchRequest)
{
  if (checkPrivateStream())
  {
    requestMsg.applyPrivateStream();
  }
  if (checkHasView() || isBatchRequest)
  {
    requestMsg.containerType(DataTypes.ELEMENT_LIST);
    if (checkHasView())
    {
      requestMsg.applyHasView();
    }
    if (isBatchRequest)
    {
      requestMsg.applyHasBatch();
    }
  }
}

相关文章