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

Input.available介绍

暂无

代码示例

代码示例来源：origin: co.paralleluniverse/quasar-core

@Override
public int available() throws IOException {
  return in.available();
}

代码示例来源：origin: co.paralleluniverse/galaxy

@Override
public int available() throws IOException {
  return in.available();
}

代码示例来源：origin: org.copper-engine/copper-monitoring-core

private void readData(Input i, Kryo kryo, long fromTime, long toTime, final boolean reverse) {
  monitoringDataList = new ArrayList<MonitoringData>();
  try {
    while (i.available() > 0) {
      try {
        Object data = kryo.readClassAndObject(i);
        if (data instanceof MonitoringData){
          MonitoringData monitoringData = (MonitoringData) data;
          if (monitoringData.getTimeStamp().getTime() <= toTime && monitoringData.getTimeStamp().getTime() >= fromTime) {
            monitoringDataList.add(monitoringData);
          }
        }
      } catch (KryoException e){
        logger.error("cant load old monitoringdata: "+e.getMessage()+" , skip file:"+file.getAbsolutePath());
        break;
      }
    }
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
  Collections.sort(monitoringDataList, new Comparator<MonitoringData>() {
    @Override
    public int compare(MonitoringData o1, MonitoringData o2) {
      return o1.getTimeStamp().compareTo(o2.getTimeStamp());
    }
  });
  if (!reverse)
    Collections.reverse(monitoringDataList);
}

代码示例来源：origin: org.apache.apex/malhar-library

@Override
 public Slice deserialize(Input input)
 {
  if (input.getInputStream() != null) {
   // The input is backed by a stream, cannot directly use its internal buffer
   try {
    return new Slice(input.readBytes(input.available()));
   } catch (IOException ex) {
    throw Throwables.propagate(ex);
   }
  } else {
   return new Slice(input.getBuffer(), input.position(), input.limit() - input.position());
  }
 }
}

代码示例来源：origin: jexp/neo4j-shell-tools

public long readBinaryDump(Input input, BatchTransaction tx, NodeCache<Long, Long> cache) throws IOException {
  if (input.available() > 0) {
    KryoSerializationTypes type = KryoSerializationTypes.valueOf(kryo.readObject(input, String.class));