class ChannelStateReaderImpl implements ChannelStateReader {

	@Override
	public ReadResult readInputData(InputChannelInfo info, Buffer buffer) throws IOException {
		Preconditions.checkState(!isClosed, "reader is closed");
		log.debug("readInputData, resultSubpartitionInfo: {} , buffer {}", info, buffer);
		ChannelStateStreamReader reader = inputChannelHandleReaders.get(info);
		return reader == null ? ReadResult.NO_MORE_DATA : reader.readInto(buffer);
	}

	public  ChannelStateReaderImpl(TaskStateSnapshot snapshot);
	  ChannelStateReaderImpl(TaskStateSnapshot snapshot, ChannelStateSerializer serializer);

}