Allow file download to be interrupted

I'm trying to download a large file (~2GB) using get(...).asFile(path) which runs on a separate thread and can take over 5 minutes to complete.

When my program exits, I try to interrupt the download thread then perform a join, but the download continues, my program does not exit and the join eventually times out.

The reason for this seems to be in FileResponse, where Files.copy(...) is used to transfer the contents of the stream to the file.
This runs in an uninterruptible loop.

One suggested option I saw is to use .asFile(path, ExtendedCopyOption.INTERRUPTIBLE) but this appears unsupported by Files.copy() (see source) and throws an exception.

Another option I tried was to use .asFileAsync() and then cancel the returned Future. However, this has a separate issue where the whole file is first downloaded to memory (see #130) which I must avoid.

Do you have any suggestion how to interrupt the copy cleanly?
Otherwise, is it something for which support could be added?

you can use void thenConsume(Consumer<RawResponse> consumer) to get direct access to the raw InputStream

Thanks, I see what you mean... then I must re-implement the functionality of FileResponse myself, and adding the interrupt handling.
That's no trouble, however I am also using a DownloadMonitor and cannot then create a MonitoringInputStream as it is package-private.

I've just published new versions with MonitoringInputStream as public.

Out of curiosity, why would you want to interrupt it anyway?

Wow, thanks for the speedy response. It's really helped simplify my code.

As I mentioned, the files I'm downloading are large and can take 5-10 minutes to download. This is happening on a worker thread. When the program closes, the worker thread is interrupted and joined. The join will time out because Files.copy() never stops copying. Of course, eventually the connection closes and the download stops, so it's not so bad. However losing a connection during a download will then appear in the logs as an exception. I was hoping to exit more 'cleanly' using the interrupt.

I'm actually looking at another problem now, that if an exception is thrown in the .thenConsume(...) method, it will get caught in the BaseApacheClient.transformBody() class. The exception handler calls recoverBody() to return the body as a string.
However this then appears to then block while it tries to read the whole ~2GB file into a string (which is then used in setParsingException()).
Can this be avoided too somehow?
If it's a problem that might need fixing, I'll gladly open a new issue for it.

Oh jeesh, thats just a bug, I'll take a look

In 3.14.4 I added two things to try and prevent the recovery part from getting the body:

If the Content-Type of the response is a known binary type (octet-stream, images, pdfs) it skips reading the body
If a UnrecoverableException is thrown it also skips it. This is what is thrown from the FileResponse class when it encounters an error. You could also throw this from the thenConsume method.

Fantastic, thanks a lot. I'll give it a try.

It works! However, I'm downloading from an AWS S3 Bucket and apparently that sets the Content-Type to binary/octet-stream. This is not in the official list of MIME types.

Unfortunately it therefore also not in the list of pre-defined types in ContentType.

I was able to define it myself (once-off, in a static block) as ContentType.create("binary/octet-stream", true).
Maybe this info might help others in the same situation.

I'm of the opinion that if AWS is using it its official enough for me :), we can add it, actually I'll add a little logic that if the MIME type contains "binary" then its binary

Sure! Not certain it helps, but another hint that it's a binary file (in this case) is the presence of the Content-Disposition: attachment header, indicating that it's a file to be downloaded (rather than to be parsed/printed etc)

Just a random comment, but I think that while making the class public the non null checks are off. Only content is verified and the rest seems like leftovers of copy/paste.

unirest-java/unirest/src/main/java/kong/unirest/core/MonitoringInputStream.java

Lines 46 to 49 in cc11894

    
           Objects.requireNonNull(content, "Original InputStream is required"); 
        
           Objects.requireNonNull(content, "ProgressMonitor is required"); 
        
           Objects.requireNonNull(content, "Valid path for file is required"); 
        
           Objects.requireNonNull(content, "RawResponse is required");

derp 🤦

fixed the requireNotNull stuff in the last release

	Objects.requireNonNull(content, "Original InputStream is required");
	Objects.requireNonNull(content, "ProgressMonitor is required");
	Objects.requireNonNull(content, "Valid path for file is required");
	Objects.requireNonNull(content, "RawResponse is required");