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

Input.readByte介绍

[英]Reads a single byte.
[中]读取单个字节。

代码示例

代码示例来源：origin: apache/incubator-dubbo

@Override
public byte readByte() throws IOException {
  try {
    return input.readByte();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

代码示例来源：origin: apache/incubator-dubbo

@Override
public byte readByte() throws IOException {
  try {
    return input.readByte();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

代码示例来源：origin: orbit/orbit

private static Object readPayload(Kryo kryo, Input in)
{
  byte payloadTypeId = in.readByte();
  if (PayloadType.OBJECT_ARRAY.id == payloadTypeId)
  {
    return kryo.readObject(in, Object[].class);
  }
  if (PayloadType.NULL.id == payloadTypeId)
  {
    return null;
  }
  return kryo.readClassAndObject(in);
}

代码示例来源：origin: orbit/orbit

private static Map<String, Object> readHeaders(Kryo kryo, Input in)
{
  int headers = in.readInt();
  if (headers == 0)
  {
    return Collections.emptyMap();
  }
  Map<String, Object> payload = new HashMap<>(headers);
  for (int i = 0; i < headers; i++)
  {
    String key = in.readString();
    byte valueTypeId = in.readByte();
    if (valueTypeId == ValueType.STRING.id)
    {
      payload.put(key, in.readString());
    }
    else if (valueTypeId == ValueType.INT.id)
    {
      payload.put(key, in.readInt());
    }
    else
    {
      payload.put(key, kryo.readClassAndObject(in));
    }
  }
  return payload;
}

代码示例来源：origin: orbit/orbit

private static Object readObjectId(Kryo kryo, Input in)
{
  byte valueTypeIdForObjectId = in.readByte();
  if (valueTypeIdForObjectId == ValueType.STRING.id)
  {
    return in.readString();
  }
  else if (valueTypeIdForObjectId == ValueType.INT.id)
  {
    return in.readInt();
  }
  else
  {
    return kryo.readClassAndObject(in);
  }
}

代码示例来源：origin: EsotericSoftware/kryonet

public void read (Kryo kryo, Input input) {
    objectID = input.readInt(true);
    int methodClassID = input.readInt(true);
    Class methodClass = kryo.getRegistration(methodClassID).getType();
    byte methodIndex = input.readByte();
    try {
      cachedMethod = getMethods(kryo, methodClass)[methodIndex];
    } catch (IndexOutOfBoundsException ex) {
      throw new KryoException("Invalid method index " + methodIndex + " for class: " + methodClass.getName());
    }
    Serializer[] serializers = cachedMethod.serializers;
    Class[] parameterTypes = cachedMethod.method.getParameterTypes();
    Object[] args = new Object[serializers.length];
    this.args = args;
    for (int i = 0, n = args.length; i < n; i++) {
      Serializer serializer = serializers[i];
      if (serializer != null)
        args[i] = kryo.readObjectOrNull(input, parameterTypes[i], serializer);
      else
        args[i] = kryo.readClassAndObject(input);
    }
    responseData = input.readByte();
  }
}

代码示例来源：origin: apache/tinkerpop

@Override
public byte readByte() {
  return unshadedInput.readByte();
}

代码示例来源：origin: orbit/orbit

@Override
public Message deserializeMessage(BasicRuntime basicRuntime, final byte[] payload) throws Exception
{
  return inputPool.run(in ->
  {
    in.setInputStream(new ByteArrayInputStream(payload));
    return kryoPool.run(kryo ->
    {
      final Message message = new Message();
      message.setMessageType(in.readByte());
      message.setMessageId(in.readInt());
      message.setReferenceAddress(readNodeAddress(in));
      message.setInterfaceId(in.readInt());
      message.setMethodId(in.readInt());
      message.setObjectId(readObjectId(kryo, in));
      message.setHeaders(readHeaders(kryo, in));
      message.setFromNode(readNodeAddress(in));
      message.setPayload(readPayload(kryo, in));
      return message;
    });
  }, DEFAULT_BUFFER_SIZE);
}

代码示例来源：origin: jobxhub/JobX

public byte readByte() throws IOException {
  try {
    return input.readByte();
  } catch (KryoException e) {
    throw new IOException(e);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo-shaded

public MonthDay read (Kryo kryo, Input in, Class<MonthDay> type) {
    byte month = in.readByte();
    byte day = in.readByte();
    return MonthDay.of(month, day);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo

public MonthDay read (Kryo kryo, Input in, Class<MonthDay> type) {
    byte month = in.readByte();
    byte day = in.readByte();
    return MonthDay.of(month, day);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo

static LocalDate read (Input in) {
    int year = in.readInt(true);
    int month = in.readByte();
    int dayOfMonth = in.readByte();
    return LocalDate.of(year, month, dayOfMonth);
  }
}

代码示例来源：origin: org.gradle/gradle-messaging

public byte readByte() throws EOFException {
  try {
    return input.readByte();
  } catch (KryoException e) {
    throw maybeEndOfStream(e);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo

public YearMonth read (Kryo kryo, Input in, Class<YearMonth> type) {
    int year = in.readInt(true);
    byte month = in.readByte();
    return YearMonth.of(year, month);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo-shaded

public YearMonth read (Kryo kryo, Input in, Class<YearMonth> type) {
    int year = in.readInt(true);
    byte month = in.readByte();
    return YearMonth.of(year, month);
  }
}

代码示例来源：origin: com.esotericsoftware/kryo

public void read (Input input, Object object) {
  try {
    field.setByte(object, input.readByte());
  } catch (Exception e) {
    KryoException ex = new KryoException(e);
    ex.addTrace(this + " (" + type.getName() + ")");
    throw ex;
  }
}

代码示例来源：origin: com.esotericsoftware/kryo-shaded

public void read (Input input, Object object) {
  try {
    field.setByte(object, input.readByte());
  } catch (Exception e) {
    KryoException ex = new KryoException(e);
    ex.addTrace(this + " (" + type.getName() + ")");
    throw ex;
  }
}

代码示例来源：origin: com.ebay.jetstream/jetstreamcore

private Object decodeAsKryo(ByteBuf frame) {
  Kryo kryo = kryoContextHolder.get().getKryo();
  Input input = new Input(new ByteBufInputStream(frame));
  input.readByte(); // skip first byte
  Object object = kryo.readClassAndObject(input);
  return object;
}

代码示例来源：origin: com.esotericsoftware/kryo

static ZoneOffset read (Input in) {
    int offsetByte = in.readByte();
    return (offsetByte == 127 ? ZoneOffset.ofTotalSeconds(in.readInt()) : ZoneOffset.ofTotalSeconds(offsetByte * 900));
  }
}

代码示例来源：origin: pl.touk.esp/esp-process

static ZoneOffset read(Input in) {
    int offsetByte = in.readByte();
    return (offsetByte == 127 ? ZoneOffset.ofTotalSeconds(in.readInt()) : ZoneOffset.ofTotalSeconds(offsetByte * 900));
  }
}