Contents

package org.embulk.decoder;

import java.io.IOException;
import java.io.InputStream;
import java.util.Iterator;

import org.apache.commons.compress.archivers.ArchiveEntry;
import org.apache.commons.compress.archivers.ArchiveInputStream;

class ArchiveInputStreamIterator implements Iterator<InputStream> {
    private ArchiveInputStream ain;
    private ArchiveEntry entry;
    private boolean endOfArchive = false;

    ArchiveInputStreamIterator(ArchiveInputStream ain)
    {
        this.ain = ain;
    }

    @Override
    public boolean hasNext() {
        try {
            return checkNext();
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public InputStream next() {
        try {
            if (checkNext()) {
                entry = null;
            } else {
                return null;
            }

            return ain;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @Override
    public void remove() {
        throw new UnsupportedOperationException();
    }

    private boolean checkNext() throws IOException {
        if (endOfArchive) {
            return false;
        } else if (entry != null) {
            return true;
        }

        while (true) {
            entry = ain.getNextEntry();
            if (entry == null) {
                endOfArchive = true;
                return false;
            } else if (entry.isDirectory()) {
                continue;
            } else {
                return true;
            }
        }
    }
}

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
embulk-decoder-commons-compress-0.3.3	src/main/java/org/embulk/decoder/ArchiveInputStreamIterator.java
embulk-decoder-commons-compress-0.3.2	src/main/java/org/embulk/decoder/ArchiveInputStreamIterator.java
embulk-decoder-commons-compress-0.3.1	src/main/java/org/embulk/decoder/ArchiveInputStreamIterator.java
embulk-decoder-commons-compress-0.3.0	src/main/java/org/embulk/decoder/ArchiveInputStreamIterator.java