package com.walker.di.support;

import com.walker.di.AbstractDataImportor;

import java.io.IOException;
import java.io.InputStream;

public abstract class InputStreamDataImportor extends AbstractDataImportor {

    protected void checkSource(Object source){
        if(!(source instanceof InputStream)){
            throw new IllegalArgumentException("source必须是:InputStream");
        }
    }

    /**
     * 释放加载的原始导入文件流。
     * @param source
     * @date 2023-02-07
     */
    protected void releaseSource(Object source){
        if(source == null){
            return;
        }
        if(source instanceof InputStream){
            InputStream inputStream = (InputStream)source;
            try {
                inputStream.close();
            } catch (IOException e) {
                logger.error("释放导入原始流出错, source.close():" + e.getMessage());
            }
        }
    }
}