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

YieldCurveRequest.streamId介绍

暂无

代码示例

代码示例来源：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 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

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 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 redirectToPrivateStream(int streamId, ReactorErrorInfo errorInfo)
{
  WatchListEntry wle = watchList.get(streamId);
  /* remove non-private stream entry from list */
  removeYieldCurveItemEntry(streamId);
  /* add item name to private stream list */
  Integer psStreamId = watchList.add(domainType, wle.itemName, true);
  generateRequest(yieldCurveRequest, true, redirectSrcDirInfo, redirectLoginInfo);
  yieldCurveRequest.itemNames().add(wle.itemName);
  yieldCurveRequest.streamId(psStreamId);
  return encodeAndSendRequest(redirectChnl, yieldCurveRequest, errorInfo);
}

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

private int redirectToPrivateStream(int streamId, com.thomsonreuters.upa.transport.Error error)
  {
    WatchListEntry wle = watchList.get(streamId);

    /* remove non-private stream entry from list */
    removeYieldCurveItemEntry(streamId);

    /* add item name to private stream list */
    Integer psStreamId = watchList.add(domainType, wle.itemName, true);

    generateRequest(yieldCurveRequest, true, redirectSrcDirInfo, redirectLoginInfo);
    yieldCurveRequest.itemNames().add(wle.itemName);
    yieldCurveRequest.streamId(psStreamId);
    return encodeAndSendRequest(redirectChnl, yieldCurveRequest, error);
  }
}

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

requestMsg.streamId(streamId());
requestMsg.domainType(domainType);
requestMsg.containerType(DataTypes.NO_DATA);