1. 包列表
  2. 类列表
  3. java.nio.file.ClosedDirectoryStreamException

Java 类java.nio.file.ClosedDirectoryStreamException 实例源码

项目：jimfs    文件：JimfsFileSystemCloseTest.java    
@Test
public void testOpenDirectoryStreamsClosed() throws IOException {
  Path p = fs.getPath("/foo");
  Files.createDirectory(p);

  try (DirectoryStream<Path> stream = Files.newDirectoryStream(p)) {

    fs.close();

    try {
      stream.iterator();
      fail();
    } catch (ClosedDirectoryStreamException expected) {
    }
  }
}
项目：OpenJSharp    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：jdk8u-jdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：openjdk-jdk10    文件：JrtDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");
    try {
        itr = dir.jrtfs.iteratorOf(dir, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        @Override
        public boolean hasNext() {
            synchronized (JrtDirectoryStream.this) {
                if (isClosed)
                    return false;
                return itr.hasNext();
            }
        }

        @Override
        public Path next() {
            synchronized (JrtDirectoryStream.this) {
                if (isClosed)
                    throw new NoSuchElementException();
                return itr.next();
            }
        }
    };
}
项目：openjdk-jdk10    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：openjdk9    文件：JrtDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");
    try {
        itr = dir.jrtfs.iteratorOf(dir, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public synchronized boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：openjdk9    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：jdk8u_jdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：lookaside_java-1.8.0-openjdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：infobip-open-jdk-8    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：jdk8u-dev-jdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：ephemeralfs    文件：EphemeralFsSecureDirectoryStream.java    
@Override
public void assertNotClosed() throws FileSystemException {
    if(closed) {
        throw new ClosedDirectoryStreamException(); 
    }

}
项目：jigsaw-jrtfs    文件：JrtDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = jrtfs.iteratorOf(path, childPrefix, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：jdk7-jdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：archive-fs    文件：TarDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed) {
        throw new ClosedDirectoryStreamException();
    }
    if (itr != null) {
        throw new IllegalStateException("Iterator has already been returned");
    }

    try {
        itr = tarfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        @SuppressWarnings("unused")
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed) {
                return false;
            }
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed) {
                throw new NoSuchElementException();
            }
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：openjdk-source-code-learn    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：OLD-OpenJDK8    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：niotest    文件：Tests07Closed.java    
@Test( expected = ClosedDirectoryStreamException.class )
@Category( Closable.class )
@SuppressWarnings( "PMD.UnusedLocalVariable" )
public void testReadFromDirStreamOfClosedFSThrows() throws IOException {
    for ( Path kid : getClosedDirStream()) {
    }
}
项目：openjdk-jdk7u-jdk    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：openjdk-icedtea7    文件：ZipDirectoryStream.java    
@Override
public synchronized Iterator<Path> iterator() {
    if (isClosed)
        throw new ClosedDirectoryStreamException();
    if (itr != null)
        throw new IllegalStateException("Iterator has already been returned");

    try {
        itr = zipfs.iteratorOf(path, filter);
    } catch (IOException e) {
        throw new IllegalStateException(e);
    }
    return new Iterator<Path>() {
        private Path next;
        @Override
        public boolean hasNext() {
            if (isClosed)
                return false;
            return itr.hasNext();
        }

        @Override
        public synchronized Path next() {
            if (isClosed)
                throw new NoSuchElementException();
            return itr.next();
        }

        @Override
        public void remove() {
            throw new UnsupportedOperationException();
        }
    };
}
项目：mycore    文件：MCRDirectoryStream.java    
void checkClosed() {
    if (dir == null) {
        throw new ClosedDirectoryStreamException();
    }
}
项目：ParallelGit    文件：GfsDirectoryStream.java    
@Nonnull
@Override
public Iterator<Path> iterator() {
  final Iterator<String> childrenIt = children.iterator();
  return new Iterator<Path>() {

    private Path next;

    private boolean findNext() {
      while(childrenIt.hasNext()) {
        String child = childrenIt.next();
        GitPath childPath = parent.resolve(child);
        try {
          if(filter == null || filter.accept(childPath)) {
            next = childPath;
            return true;
          }
        } catch(IOException ignore) {
        }
      }
      return false;
    }

    @Override
    public boolean hasNext() throws ClosedDirectoryStreamException {
      checkNotClosed();
      return next != null || findNext();
    }

    @Nonnull
    @Override
    public Path next() throws ClosedDirectoryStreamException, NoSuchElementException {
      checkNotClosed();
      if(next != null || hasNext()) {
        Path ret = next;
        next = null;
        return ret;
      }
      throw new NoSuchElementException();
    }

    @Override
    public void remove() throws UnsupportedOperationException {
      throw new UnsupportedOperationException();
    }
  };
}
项目：ParallelGit    文件：GfsDirectoryStream.java    
private void checkNotClosed() throws ClosedDirectoryStreamException {
  if(closed)
    throw new ClosedDirectoryStreamException();
}
项目：ParallelGit    文件：GfsDirectoryStream.java    
@Nonnull
@Override
public Iterator<Path> iterator() {
  final Iterator<String> childrenIt = children.iterator();
  return new Iterator<Path>() {

    private Path next;

    private boolean findNext() {
      while(childrenIt.hasNext()) {
        String child = childrenIt.next();
        GitPath childPath = parent.resolve(child);
        try {
          if(filter == null || filter.accept(childPath)) {
            next = childPath;
            return true;
          }
        } catch(IOException ignore) {
        }
      }
      return false;
    }

    @Override
    public boolean hasNext() throws ClosedDirectoryStreamException {
      checkNotClosed();
      return next != null || findNext();
    }

    @Nonnull
    @Override
    public Path next() throws ClosedDirectoryStreamException, NoSuchElementException {
      checkNotClosed();
      if(next != null || hasNext()) {
        Path ret = next;
        next = null;
        return ret;
      }
      throw new NoSuchElementException();
    }

    @Override
    public void remove() throws UnsupportedOperationException {
      throw new UnsupportedOperationException();
    }
  };
}
项目：ParallelGit    文件：GfsDirectoryStream.java    
private void checkNotClosed() throws ClosedDirectoryStreamException {
  if(closed)
    throw new ClosedDirectoryStreamException();
}
项目：jimfs    文件：JimfsSecureDirectoryStream.java    
protected synchronized void checkOpen() {
  if (!open) {
    throw new ClosedDirectoryStreamException();
  }
}