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

Input.setInputStream介绍

[英]Sets a new InputStream. The position and total are reset, discarding any buffered bytes.
[中]设置新的InputStream。重置位置和总数，丢弃所有缓冲字节。

代码示例

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

@Override
 protected boolean recycle(Input input) {
  if (input.getBuffer().length < MAX_POOLED_BUFFER_SIZE) {
   input.setInputStream(null);
   return true;
  }
  return false; // discard
 }
}

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

@Override
  protected boolean recycle(Input input)
  {
    if (input.getBuffer().length < MAX_POOLED_BUFFER_SIZE)
    {
      input.setInputStream(null);
      return true;
    }
    return false; // discard
  }
}

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

/**
 * Deserializes given byte array to Object using Kryo instance in pool.
 *
 * @param bytes serialized bytes
 * @param <T>   deserialized Object type
 * @return deserialized Object
 */
public <T> T deserialize(final byte[] bytes) {
 return kryoInputPool.run(input -> {
  input.setInputStream(new ByteArrayInputStream(bytes));
  return kryoPool.run(kryo -> {
   @SuppressWarnings("unchecked")
   T obj = (T) kryo.readClassAndObject(input);
   return obj;
  });
 }, DEFAULT_BUFFER_SIZE);
}

代码示例来源：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: com.esotericsoftware/kryo

public void setInputStream (InputStream inputStream) {
  super.setInputStream(inputStream);
  chunkSize = -1;
}

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

public void setInputStream (InputStream inputStream) {
  super.setInputStream(inputStream);
  chunkSize = -1;
}

代码示例来源：origin: com.twitter/chill-java

public void setInput(InputStream in) { input.setInputStream(in); }

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

public void setInputStream (InputStream inputStream) {
  super.setInputStream(inputStream);
  chunkSize = -1;
}

代码示例来源：origin: svn2github/kryo

public void setInputStream (InputStream inputStream) {
  super.setInputStream(inputStream);
  chunkSize = -1;
}

代码示例来源：origin: tv.cntt/chill-scala-2-11

public void setInput(InputStream in) { input.setInputStream(in); }

代码示例来源：origin: usc-cloud/goffish

@Override
public Input prepareStream(InputStream stream) throws IOException {
  Input input = new Input(_bufferSize);
  input.setInputStream(stream);
  return input;
}

代码示例来源：origin: io.atomix/atomix-utils

@Override
  protected boolean recycle(Input input) {
    if (input.getBuffer().length < MAX_POOLED_BUFFER_SIZE) {
      input.setInputStream(null);
      return true;
    }
    return false; // discard
  }
}

代码示例来源：origin: org.apache.giraph/giraph-core

/**
 * Constructor
 *
 * @param fileName file name
 * @param buffer reusable byte buffer that will be used in Kryo's Input
 *               reader
 * @throws IOException
 */
@edu.umd.cs.findbugs.annotations.SuppressWarnings(
  "OBL_UNSATISFIED_OBLIGATION")
LocalDiskDataInputWrapper(String fileName, byte[] buffer)
  throws IOException {
 file = new File(fileName);
 if (LOG.isDebugEnabled()) {
  LOG.debug("LocalDiskDataInputWrapper: obtaining a data input from " +
    "local file " + file.getAbsolutePath());
 }
 input = new UnsafeInput(buffer);
 input.setInputStream(new FileInputStream(
   new RandomAccessFile(file, "r").getFD()));
}

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

@Override
public Object read(InputStream is) throws IOException {
  final Input in = getInput();
  in.setInputStream(is);
  return kryo.readClassAndObject(in);
}

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

public <T> T read(InputStream is, Class<T> type) {
    final Input in = getInput();
    in.setInputStream(is);
    return kryo.readObjectOrNull(input, type);
  }
}

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

public <T> T read(InputStream is, Class<T> type) {
    final Input in = getInput();
    in.setInputStream(is);
    return kryo.readObjectOrNull(input, type);
  }
}

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

@Override
public Object read(InputStream is) throws IOException {
  final Input in = getInput();
  in.setInputStream(is);
  return kryo.readClassAndObject(in);
}

代码示例来源：origin: io.atomix/atomix-utils

/**
 * Deserializes given byte array to Object using Kryo instance in pool.
 *
 * @param bytes serialized bytes
 * @param <T>   deserialized Object type
 * @return deserialized Object
 */
public <T> T deserialize(final byte[] bytes) {
 return kryoInputPool.run(input -> {
  input.setInputStream(new ByteArrayInputStream(bytes));
  return kryoPool.run(kryo -> {
   @SuppressWarnings("unchecked")
   T obj = (T) kryo.readClassAndObject(input);
   return obj;
  });
 }, DEFAULT_BUFFER_SIZE);
}