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

Input.eof介绍

暂无

代码示例

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

if (input.eof()) {
 input.close();
 input = null;

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

if (input.eof()) {
 input.close();
 input = null;

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

pair.setSecond(readValue(input));
if (input.eof()) {
 input.close();
 input = null;

代码示例来源：origin: com.tinkerpop/gremlin-core

@Override
public boolean hasNext() {
  return !input.eof();
}

代码示例来源：origin: seznam/euphoria

@Override
public boolean eof() {
 return input.eof();
}

代码示例来源：origin: davidmoten/rxjava-extras

@Override
  protected Input next(Input arg0, Observer<? super T> observer) {
    if (input.eof()) {
      observer.onCompleted();
    } else {
      T t = kryo.readObject(input, cls);
      observer.onNext(t);
    }
    return input;
  }
});

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

try {
 LOG.debug("Start replaying WAL");
 while (!in.eof()) {
  final int opId = in.readInt();
  final RecoverableOperation recoverableOperation = RecoverableOperation.get(opId);

代码示例来源：origin: davidmoten/rxjava2-extras

@Override
public void accept(Emitter<T> emitter) throws Exception {
  if (input.eof()) {
    emitter.onComplete();
  } else {
    T t = kryo.readObject(input, cls);
    emitter.onNext(t);
  }
}

代码示例来源：origin: com.github.davidmoten/rxjava-extras

@Override
  protected Input next(Input arg0, Observer<? super T> observer) {
    if (input.eof()) {
      observer.onCompleted();
    } else {
      T t = kryo.readObject(input, cls);
      observer.onNext(t);
    }
    return input;
  }
});

代码示例来源：origin: com.github.davidmoten/rxjava2-extras

@Override
public void accept(Emitter<T> emitter) throws Exception {
  if (input.eof()) {
    emitter.onComplete();
  } else {
    T t = kryo.readObject(input, cls);
    emitter.onNext(t);
  }
}

代码示例来源：origin: com.tinkerpop/gremlin-core

/**
 * Read the edges from the temp file and load them to the graph.
 */
private void readFromTempEdges(final Input input, final Graph graphToWriteTo) {
  while (!input.eof()) {
    // in this case the outId is the id assigned by the graph
    Object next = kryo.readClassAndObject(input);
    while (!next.equals(EdgeTerminator.INSTANCE)) {
      final List<Object> edgeArgs = new ArrayList<>();
      final DetachedEdge detachedEdge = (DetachedEdge) next;
      final Vertex vOut = graphToWriteTo.iterators().vertexIterator(detachedEdge.iterators().vertexIterator(Direction.OUT).next().id()).next();
      final Vertex inV = graphToWriteTo.iterators().vertexIterator(detachedEdge.iterators().vertexIterator(Direction.IN).next().id()).next();
      detachedEdge.iterators().propertyIterator().forEachRemaining(p -> edgeArgs.addAll(Arrays.asList(p.key(), p.value())));
      appendToArgList(edgeArgs, T.id, detachedEdge.id());
      vOut.addEdge(detachedEdge.label(), inV, edgeArgs.toArray());
      next = kryo.readClassAndObject(input);
    }
    // vertex terminator
    kryo.readClassAndObject(input);
  }
}

代码示例来源：origin: com.tinkerpop/gremlin-core

while (!input.eof()) {
  final List<Object> vertexArgs = new ArrayList<>();
  final DetachedVertex current = (DetachedVertex) kryo.readClassAndObject(input);