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

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

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

Buffer.decode介绍

[英]Decodes a Buffer.
[中]解码缓冲区。

代码示例

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rsslBuffer.decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
  }
}

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

@Override
void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, int majVer, int minVer,
    com.thomsonreuters.upa.codec.DataDictionary rsslDictionary, Object localFlSetDefDb)
{
  _rsslDecodeIter.clear();
  
  if ((_rsslDecodeIter.setBufferAndRWFVersion(rsslBuffer, _rsslMajVer, _rsslMinVer)) != CodecReturnCodes.SUCCESS)
  {
    _dataCode = DataCode.BLANK;
    return;
  }
  if (_rsslBuffer.decode(_rsslDecodeIter) == CodecReturnCodes.SUCCESS)
    _dataCode = DataCode.NO_CODE;
  else
    _dataCode = DataCode.BLANK;
}

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

@Override
void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, int majVer, int minVer, com.thomsonreuters.upa.codec.DataDictionary rsslDictionary, Object obj)
{
  _rsslDecodeIter.clear();
  
  if ((_rsslDecodeIter.setBufferAndRWFVersion(rsslBuffer, _rsslMajVer, _rsslMinVer)) != CodecReturnCodes.SUCCESS)
  {
    _dataCode = DataCode.BLANK;
    return;
  }
  if (_rsslBuffer.decode(_rsslDecodeIter) == CodecReturnCodes.SUCCESS)
    _dataCode = DataCode.NO_CODE;
  else
    _dataCode = DataCode.BLANK;
}

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

@Override
void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, int majVer, int minVer,
      com.thomsonreuters.upa.codec.DataDictionary rsslDictionary, Object localFlSetDefDb)
{
  _rsslDecodeIter.clear();
  
  if ((_rsslDecodeIter.setBufferAndRWFVersion(rsslBuffer, _rsslMajVer, _rsslMinVer)) != CodecReturnCodes.SUCCESS)
  {
    _dataCode = DataCode.BLANK;
    return;
  }
  if ((_rsslBuffer.decode(_rsslDecodeIter)) == CodecReturnCodes.SUCCESS)
    _dataCode = DataCode.NO_CODE;
  else
    _dataCode = DataCode.BLANK;
}

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

@Override
  void decode(com.thomsonreuters.upa.codec.Buffer rsslBuffer, com.thomsonreuters.upa.codec.DecodeIterator dIter)
  {
    if (_rmtesBuffer.applyToCache())
      _rmtesBuffer.clear();
    
    if (_rmtesBuffer.rsslBuffer().decode(dIter) == CodecReturnCodes.SUCCESS)
      _dataCode = DataCode.NO_CODE;
    else
      _dataCode = DataCode.BLANK;
    
    _rsslBuffer = _rmtesBuffer.rsslBuffer();
  }
}

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

case DataTypes.UTF8_STRING:
case DataTypes.RMTES_STRING:
  ret = fidBufferValue.decode(dIter);
  if (ret == CodecReturnCodes.SUCCESS)

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

dIter.clear();
dIter.setBufferAndRWFVersion(upaBuffer, Codec.majorVersion(), Codec.minorVersion());
assertEquals(CodecReturnCodes.BLANK_DATA, buffer.decode(dIter));
dIter.clear();
dIter.setBufferAndRWFVersion(upaBuffer, Codec.majorVersion(), Codec.minorVersion());
assertEquals(CodecReturnCodes.SUCCESS, buffer.decode(dIter));
assertEquals(2, buffer.length());
assertEquals(0, buffer.position());

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

private void bufferED(Buffer buf)
{
  _encIter.clear();
  _buffer.data(ByteBuffer.allocate(15));
  _encIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
  buf.encode(_encIter);
  _decIter.clear();
  _decIter.setBufferAndRWFVersion(_buffer, Codec.majorVersion(), Codec.minorVersion());
  Buffer buf1 = CodecFactory.createBuffer();
  buf1.data(ByteBuffer.allocate(15));
  buf1.decode(_decIter);
  assertEquals(buf.toString(), buf1.toString());
  assertTrue(buf.equals(buf1));
}

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

if (_rsslItemBuffer.decode(_rsslDecodeIter) == CodecReturnCodes.SUCCESS )
  _batchItemList.add(_rsslItemBuffer.toString());

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

case DataTypes.UTF8_STRING:
case DataTypes.RMTES_STRING:
  if ((ret = _fidBufferValue.decode(iter)) < CodecReturnCodes.SUCCESS )
    return ret;
  break;

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

case DataTypes.UTF8_STRING:
case DataTypes.RMTES_STRING:
  if ((ret = _fidBufferValue.decode(iter)) < CodecReturnCodes.SUCCESS )
    return ret;
  break;

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

ret = tmpBuffer.decode(_decIter);
assertEquals(CodecReturnCodes.SUCCESS, ret);
assertEquals(6, tmpBuffer.length());

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

ret = tmpBuffer.decode(_decIter);
if (ret == CodecReturnCodes.SUCCESS)

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

assertEquals(175, fieldEntry.fieldId());
assertEquals(DataTypes.UNKNOWN, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, buffer.decode(dIter));
assertEquals("ABCDEFG", buffer.toString());

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

assertEquals(175, fieldEntry.fieldId());
assertEquals(DataTypes.UNKNOWN, fieldEntry.dataType());
assertEquals(CodecReturnCodes.SUCCESS, buffer.decode(dIter));
assertEquals("ABCDEFG", buffer.toString());

相关文章