com.dyuproject.protostuff.YamlOutput类的使用及代码示例

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

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

YamlOutput介绍

[英]An output used for writing data with yaml format.
[中]用于以yaml格式写入数据的输出。

代码示例

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

throw new IllegalArgumentException("Buffer previously used and had not been reset.");
final YamlOutput output = new YamlOutput(buffer, schema);
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      true, 
    schema.writeTo(output.writeSequenceDelim(), m);
    output.reset();
return output.getSize();

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

tail = writeTag(
    schema.messageName(), 
    repeated, 
    sink, 
    this, 
    writeKey(
        lastSchema.getFieldName(fieldNumber),
        lastIndent,
final int indentRepeated = inc(lastIndent, 2);
tail = sink.writeByteArray(
    DASH_AND_SPACE, 
    this, 
    newLine(
        indentRepeated, 
        sink, 
        tail));
indent = inc(indentRepeated, 2);
indent = inc(lastIndent, 2);

代码示例来源：origin: com.dyuproject.protostuffdb/protostuffdb-core

@Override
  public <T> Schema<?> scope(int fieldNumber, boolean push, Schema<T> schema, 
      boolean repeated) throws IOException
  {
    return yo.scope(fieldNumber, push, schema, repeated);
  }
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

YamlOutput writeSequenceDelim() throws IOException
{
  tail = sink.writeByteArray(
      DASH_AND_SPACE, 
      this, 
      newLine(
          indent, 
          sink, 
          this, 
          tail));
  
  indent = inc(indent, 2);
  return this;
}

代码示例来源：origin: com.dyuproject.protostuffdb/protostuffdb-core

public RpcResponse newRpcResponse(final Schema<?> schema, WriteContext context, 
    RpcHeader header, RpcProtocol protocol, 
    final RpcWorker worker, WriteSession session) throws IOException
{
  final YamlOutput output = this.output;
  response.worker.currentOutput = output;
  
  output.use(schema).reset();
  output.size = session.size;
  
  protocol.writeHeader(RpcError.NONE, header, this, worker, output);
  
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
      output.sink, 
      output, 
      output.sink.writeByteArray(
          YAML_START_DIRECTIVE, 
          output, 
          output.tail));
  
  return response;
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

/**
 * Serializes the {@code message} into a {@link WriteSession}.
 * 
 * @return the total bytes written to the output.
 */
public static <T> int writeTo(WriteSession session, T message, Schema<T> schema) throws IOException
{
  final int size = session.size;
  final YamlOutput output = new YamlOutput(session.head, session.out, schema);
  output.size = size;
  
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
      output.sink, 
      output, 
      output.sink.writeByteArray(
          START_DIRECTIVE, 
          output, 
          output.tail));
  
  schema.writeTo(output, message);
  
  return output.getSize() - size;
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

DASH_AND_SPACE, 
      this, 
      newLine(
          inc(indent, 2), 
          sink, 
          this, 
value, 
this, 
writeKey(
    schema.getFieldName(fieldNumber), 
    indent,

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

throw new IllegalArgumentException("Buffer previously used and had not been reset.");
final YamlOutput output = new YamlOutput(buffer, schema);
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
return output.toByteArray();

代码示例来源：origin: com.dyuproject.protostuffdb/protostuffdb-core

public Yaml(RpcProtocol protocol, 
    RpcWorker worker, WriteSession session, 
    int nextBufferSize)
{
  super("yaml", false);
  
  output = new YamlOutput(session.head, DUMMY_OUT,
      this, nextBufferSize, null);
  
  response = new Response(worker, output, protocol);
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

public void writeBytes(int fieldNumber, ByteString value, boolean repeated) throws IOException
{
  writeByteArray(fieldNumber, value.getBytes(), repeated);
}

代码示例来源：origin: com.dyuproject.protostuffdb/protostuffdb-core

public <T> boolean fail(RpcError error, T message, Schema<T> fSchema) throws IOException
{
  protocol.updateError(error, worker, yo);
  
  fSchema.writeTo(yo.use(fSchema), message);
  
  return false;
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

throw new IllegalArgumentException("Buffer previously used and had not been reset.");
final YamlOutput output = new YamlOutput(buffer, schema);
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
return output.getSize();

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

DASH_AND_SPACE, 
      this, 
      newLine(
          inc(indent, 2), 
          sink, 
          this, 
value ? TRUE : FALSE, 
this, 
writeKey(
    schema.getFieldName(fieldNumber), 
    indent,

代码示例来源：origin: com.dyuproject.protostuffdb/protostuffdb-core

public <T> RpcError writeError(RpcError error, T message, Schema<T> schema, 
    RpcHeader header, RpcProtocol protocol, 
    RpcWorker worker, WriteSession session) throws IOException
{
  final YamlOutput output = this.output;
  response.worker.currentOutput = output;
  
  output.use(schema).reset();
  output.size = session.size;
  
  protocol.writeHeader(error, header, this, worker, output);
  
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
      output.sink, 
      output, 
      output.sink.writeByteArray(
          YAML_START_DIRECTIVE, 
          output, 
          output.tail));
  
  schema.writeTo(output, message);
  
  return error;
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

private static LinkedBuffer writeKey(final String name, final int indent, 
    final boolean repeated, final WriteSink sink, 
    final WriteSession session, LinkedBuffer lb) throws IOException
{
  lb = sink.writeByteArray(
      COLON_AND_SPACE, 
      session, 
      sink.writeStrAscii(
          name, 
          session, 
          newLine(
              indent, 
              sink, 
              session, 
              lb)));
  if(repeated)
  {
    return sink.writeByteArray(
        DASH_AND_SPACE, 
        session, 
        newLine(
            inc(indent, 2), 
            sink, 
            session, 
            lb));
  }
  
  return lb;
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

throw new IllegalArgumentException("Buffer previously used and had not been reset.");
final YamlOutput output = new YamlOutput(buffer, out, schema);
output.tail = YamlOutput.writeTag(
    schema.messageName(), 
    true, 
  schema.writeTo(output.writeSequenceDelim(), m);
  output.reset();
return output.getSize();

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

/**
 * Serializes the {@code message} into an {@link OutputStream} 
 * with the supplied buffer.
 * 
 * @return the total bytes written to the output.
 */
public static <T> int writeTo(OutputStream out, T message, Schema<T> schema, 
    LinkedBuffer buffer) throws IOException
{
  if(buffer.start != buffer.offset)
    throw new IllegalArgumentException("Buffer previously used and had not been reset.");
  
  final YamlOutput output = new YamlOutput(buffer, out, schema);
  
  output.tail = YamlOutput.writeTag(
      schema.messageName(), 
      false, 
      output.sink, 
      output, 
      output.sink.writeByteArray(
          START_DIRECTIVE, 
          output, 
          buffer));
  
  schema.writeTo(output, message);
  LinkedBuffer.writeTo(out, buffer);
  
  return output.getSize();
}

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

DASH_AND_SPACE, 
      this, 
      newLine(
          inc(indent, 2), 
          sink, 
          this, 
value, 
this, 
writeKey(
    schema.getFieldName(fieldNumber), 
    indent,

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

tail = writeTag(
    schema.messageName(), 
    repeated, 
    sink, 
    this, 
    writeKey(
        lastSchema.getFieldName(fieldNumber),
        lastIndent,
final int indentRepeated = inc(lastIndent, 2);
tail = sink.writeByteArray(
    DASH_AND_SPACE, 
    this, 
    newLine(
        indentRepeated, 
        sink, 
        tail));
indent = inc(indentRepeated, 2);
indent = inc(lastIndent, 2);

代码示例来源：origin: com.dyuproject.protostuff/protostuff-yaml

DASH_AND_SPACE, 
      this, 
      newLine(
          inc(indent, 2), 
          sink, 
          this, 
value, 
this, 
writeKey(
    schema.getFieldName(fieldNumber), 
    indent,

内容来源于网络，如有侵权，请联系作者删除！

YamlOutput

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com