com.github.junrar.Archive.getInputStream()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(79)

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

Archive.getInputStream介绍

[英]Returns an InputStream that will allow to read the file and stream it. Please note that this method will create a new Thread and an a pair of Pipe streams.
[中]返回允许读取文件并对其进行流式处理的InputStream。请注意,此方法将创建一个新线程和一对管道流。

代码示例

代码示例来源:origin: apache/tika

while (header != null && !Thread.currentThread().isInterrupted()) {
  if (!header.isDirectory()) {
    try (InputStream subFile = rar.getInputStream(header)) {
      Metadata entrydata = PackageParser.handleEntryMetadata(
          "".equals(header.getFileNameW()) ? header.getFileNameString() : header.getFileNameW(),

代码示例来源:origin: com.github.junrar/junrar

@Override
protected InputStream doGetInputStream() throws Exception {
  if (!getType().hasContent()) {
    throw new FileSystemException("vfs.provider/read-not-file.error",
        getName());
  }
  return archive.getInputStream(header);
}

代码示例来源:origin: edmund-wagner/junrar

@Override
protected InputStream doGetInputStream() throws Exception {
  if (!getType().hasContent()) {
    throw new FileSystemException("vfs.provider/read-not-file.error",
        getName());
  }
  return archive.getInputStream(header);
}

代码示例来源:origin: digital-preservation/droid

private void processEntry(FileHeader entry, Archive archive, URI uri, String newPath) throws CommandExecutionException, IOException, RarException {
    String name = entry.getFileNameString();

    if (!entry.isDirectory()) {
      final RequestMetaData metaData = new RequestMetaData(entry.getUnpSize(), 2L, name);
      final RequestIdentifier identifier = new RequestIdentifier(uri);
      RarIdentificationRequest req = new RarIdentificationRequest(metaData, identifier, getTmpDir());
      expandContainer(req, archive.getInputStream(entry), newPath);
    } else {
      log.trace("processing directory : " + entry.getFileNameString());
    }
  }
}

代码示例来源:origin: digital-preservation/droid

private void submitFile(FileHeader entry) throws IOException, URISyntaxException, RarException {
  String fullpath = entry.getFileNameString();
  String path = FilenameUtils.getPath(fullpath);
  String name = FilenameUtils.getName(fullpath);
  //CHECKSTYLE:OFF
  log.debug("submitFile, processing path: " + path + " name: " + name);
  //CHECKSTYLE:ON
  ResourceId correlationId = getFromDirCache(path);
  if (correlationId == null) {
    correlationId = submitDirectory(path, entry.getMTime());
  }
  InputStream entryInputStream = archive.getInputStream(entry);
  RequestIdentifier identifier = new RequestIdentifier(ArchiveFileUtils.toRarUri(parentURI, path + name));
  identifier.setAncestorId(originatorNodeId);
  identifier.setParentResourceId(correlationId);
  RequestMetaData metaData = new RequestMetaData(entry.getUnpSize(),
      entry.getMTime().getTime(), name);
  IdentificationRequest<InputStream> request = identificationRequestFactory.newRequest(metaData, identifier);
  request.open(entryInputStream);
  droid.submit(request);
}

代码示例来源:origin: uk.gov.nationalarchives/droid-core-interfaces

private void submitFile(FileHeader entry) throws IOException, URISyntaxException, RarException {
  String fullpath = entry.getFileNameString();
  String path = FilenameUtils.getPath(fullpath);
  String name = FilenameUtils.getName(fullpath);
  //CHECKSTYLE:OFF
  log.debug("submitFile, processing path: " + path + " name: " + name);
  //CHECKSTYLE:ON
  ResourceId correlationId = getFromDirCache(path);
  if (correlationId == null) {
    correlationId = submitDirectory(path, entry.getMTime());
  }
  InputStream entryInputStream = archive.getInputStream(entry);
  RequestIdentifier identifier = new RequestIdentifier(ArchiveFileUtils.toRarUri(parentURI, path + name));
  identifier.setAncestorId(originatorNodeId);
  identifier.setParentResourceId(correlationId);
  RequestMetaData metaData = new RequestMetaData(entry.getUnpSize(),
      entry.getMTime().getTime(), name);
  IdentificationRequest<InputStream> request = identificationRequestFactory.newRequest(metaData, identifier);
  request.open(entryInputStream);
  droid.submit(request);
}

代码示例来源:origin: com.github.lafa.tikaNoExternal/tika-parsers

while (header != null && !Thread.currentThread().isInterrupted()) {
  if (!header.isDirectory()) {
    try (InputStream subFile = rar.getInputStream(header)) {
      Metadata entrydata = PackageParser.handleEntryMetadata(
          "".equals(header.getFileNameW()) ? header.getFileNameString() : header.getFileNameW(),

代码示例来源:origin: org.apache.tika/tika-parsers

while (header != null && !Thread.currentThread().isInterrupted()) {
  if (!header.isDirectory()) {
    try (InputStream subFile = rar.getInputStream(header)) {
      Metadata entrydata = PackageParser.handleEntryMetadata(
          "".equals(header.getFileNameW()) ? header.getFileNameString() : header.getFileNameW(),

相关文章