Method run

CodenameOne/src/com/codename1/io/Util.java:3196–3238

()

            public void actionPerformed(NetworkEvent evt) {
                mergeFilesThread.run(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            // We append the just saved partial download to the fileName, if it exists
                            if (FileSystemStorage.getInstance().exists(partialDownloadPath)) {
                                InputStream in = null; //NOPMD CloseResource
                                try {
                                    in = FileSystemStorage.getInstance().openInputStream(partialDownloadPath);
                                    Util.copyNoClose(in, out, 8192);
                                } finally {
                                    Util.cleanup(in);
                                }
                                // before deleting the file, we check and update how much data we have actually downloaded
                                downloadedTotalBytes.set(downloadedTotalBytes.get() + FileSystemStorage.getInstance().getLength(partialDownloadPath));
                                FileSystemStorage.getInstance().delete(partialDownloadPath);
                            }
                            // Is the download finished?
                            if (downloadedTotalBytes.get() > fileSize) {
                                throw new IllegalStateException("More content has been downloaded than the file length, check the code.");
                            }
                            if (fileSize <= 0 || downloadedTotalBytes.get() == fileSize) {
                                // yes, download finished
                                Util.cleanup(out);
                                if (filesavedCallback != null) {
                                    CN.callSerially(new Runnable() {
                                        @Override
                                        public void run() {
                                            filesavedCallback.completed(fileName);
                                        }
                                    });
                                }
                            } else {
                                // no, it's not finished, we repeat the request after updating the "Range" header
                                cr.addRequestHeader("Range", "bytes=" + downloadedTotalBytes.get() + "-" + (Math.min(downloadedTotalBytes.get() + splittingSize, fileSize)));
                                NetworkManager.getInstance().addToQueue(cr);
                            }

                        } catch (IOException ex) {
                            Log.p("Error in appending splitted file to output file", Log.ERROR);
                            Log.e(ex);
                            Log.sendLogAsync();
                        }
                    }
                });
            }
        });