Fixed having an error doesn't inform external listeners

This commit is contained in:
Viktor De Pasquale 2019-10-22 16:22:28 +02:00
parent 2bb39bee2f
commit a230d63cf9

View File

@ -76,7 +76,7 @@ abstract class RemoteFileService : NotificationService() {
}.doOnComplete { }.doOnComplete {
if (subject is Manager) if (subject is Manager)
handleAPK(subject) handleAPK(subject)
} }.doOnError { send(0f, subject) }
private fun ResponseBody.toStream(id: Int, subject: DownloadSubject): InputStream { private fun ResponseBody.toStream(id: Int, subject: DownloadSubject): InputStream {
val maxRaw = contentLength() val maxRaw = contentLength()