从远程下载文件并将其保存到 Android 台设备
Downloading a file from remote and save it to an Android device
我想做的是解耦文件的下载方式与我将文件保存到存储的方式。
正常运行的代码：
以下代码从远程下载一个文件，最后保存到存储中。
private fun downloadFile(url: URL): Observable<Int> {
return Observable.create(fun(emitter)
{
var input: InputStream? = null
var output: OutputStream? = null
var connection: HttpURLConnection? = null
val path = Environment.getExternalStorageDirectory().path
try
{
connection = url.openConnection() as HttpURLConnection
if (connection != null)
{
connection.connect()
if (connection.responseCode != HttpURLConnection.HTTP_OK)
{
emitter.onError(IllegalStateException("<HTTP Error> ${connection.responseMessage}. Status code: ${connection.responseCode}."))
return
}
if (connection.contentType == null)
{
emitter.onError(IllegalStateException("<HTTP Error> Unsupported content-type."))
return
}
val fileLength = connection.contentLength
var fileext = MimeTypeMap.getSingleton().getExtensionFromMimeType(connection.contentType)
input = connection.inputStream
output = FileOutputStream("/$path/SmartTVMediaTest.$fileext")
val data = ByteArray(4096)
var totalBytesReceived: Int = 0
while (!emitter.isDisposed)
{
val receivedBytes: Int = input.read(data)
if (receivedBytes < 0)
{
break
}
totalBytesReceived += receivedBytes
if (fileLength > 0)
{
val portion = totalBytesReceived / fileLength.toFloat()
val percentage = portion * 100
emitter.onNext(percentage.toInt())
Log.d(TAG, "<downloadFile> $fileLength, $totalBytesReceived, $percentage")
}
output.write(data, 0, receivedBytes)
}
emitter.onComplete()
}
else {
emitter.onError(IllegalStateException("<HTTP Connection Error> Unsupported connection type."))
}
}
catch(ex: InterruptedException) {
Log.d(TAG, "<Thread> Download cancelled.")
}
catch (ex: IOException)
{
emitter.onError(ex)
}
finally
{
input?.close()
output?.close()
connection?.disconnect()
}
})
}
无效的代码：
所以我开始创建一个 class 来表示从远程读取的数据块，如下所示：
public data class DownloadChunk(val data: ByteArray, val length: Int, val totalLength: Int)
然后我创建了下载文件的可观察对象，如下所示：
public class DownloadServiceObservable
{
public fun download(url: URL): Observable<DownloadChunk>
{
return Observable.create(fun(emitter)
{
var input: InputStream? = null
var connection: HttpURLConnection? = null
try
{
connection = url.openConnection() as HttpURLConnection
if (connection != null)
{
connection.connect()
if (connection.responseCode != HttpURLConnection.HTTP_OK)
{
emitter.onError(IllegalStateException("<HTTP Error> ${connection.responseMessage}. Status code: ${connection.responseCode}."))
return
}
if (connection.contentType == null)
{
emitter.onError(IllegalStateException("<HTTP Error> Unsupported content-type."))
return
}
val totalLength = connection.contentLength
input = connection.inputStream
val data = ByteArray(4096)
while (!emitter.isDisposed)
{
val length: Int = input.read(data)
if (length < 0)
{
break
}
emitter.onNext(DownloadChunk(data, length, totalLength))
}
emitter.onComplete()
}
else
{
emitter.onError(IllegalStateException("<HTTP Connection Error> Unsupported connection type."))
}
}
catch(ex: InterruptedException)
{
emitter.onError(ex)
}
finally
{
input?.close()
connection?.disconnect()
}
})
}
}
最后，我创建了一个 Observer 将文件保存到设备，如下所示：
public class DownloadFileObserver: Observer<DownloadChunk>
{
private val _file: OutputStream
public override fun onSubscribe(d: Disposable)
{
}
public constructor(path: String)
{
_file = FileOutputStream(path)
}
public override fun onNext(chunk: DownloadChunk)
{
_file.write(chunk.data, 0, chunk.length)
}
public override fun onError(e: Throwable)
{
_file.close()
}
public override fun onComplete()
{
_file.close()
}
}
问题：
DownloadFileObserver 创建的文件已损坏，所以我的第一个假设是在推送和接收项目之间不能保证 onNext 的顺序，但据我所知是，我通过在 observable 中添加一个计数器来测试它，并在观察者中打印计数器。
我想我错过了什么。
您需要测试您的代码，正如您所知，试图检查代码以查看错误只是一种挫败感。
首先，测试您的观察者（用 Java 编写的代码，对于 JUnit 4，抱歉）：
@Test
public void testObserver() {
DownloadFileObserver uut = new DownloadFileObserver("testpath.txt");
bytes[] testData = "Test String".getBytes();
uut.onNext( new DownloadChunk( testData, testData.length, testData.length );
uut.onComplete();
// inspect the result
bytes[] resultData = Files.readAllBytes( Paths.get( "testpath.txt" );
assertTrue( Arrays.equals( testData, resultData );
}
然后开始添加处理多个块的测试，然后是错误。
最后，为您的 DownloadServiceObservable 编写单元测试。这些将更加困难，因为您将需要模拟实际的网络调用。
我设法通过测试重现了这个问题，这是一个线程问题，我订阅并观察了两个不同的线程，所以我读取和写入数据的顺序不同步，所以我最终重构了 DownloadServiceObservable 现在它需要一个 StreamFactory 的实例来处理从给定源获取流以及 StreamWriter 的实例负责将数据写入给定的目的地所以现在所有工作都在后台完成。
澄清一下 StreamFactory 和 StreamWriter 是我创建的两个接口。
现在，DownloadServiceObservable 看起来像这样：
public class DownloadServiceObservable
{
private val _source: StreamFactory
private val _destination: StreamWriter
public constructor(source: StreamFactory, destination: StreamWriter)
{
_source = source
_destination = destination
}
public fun download(): Observable<DownloadProgress>
{
return Observable.create(fun(emitter)
{
var input: InputStream? = null
try {
input = _source.create()
if (input != null) {
val data = ByteArray(4096)
var totalBytesReceived = 0
while (!emitter.isDisposed) {
val receivedBytes: Int = input.read(data)
if (receivedBytes < 0) {
break
}
totalBytesReceived += receivedBytes
emitter.onNext(DownloadProgress(totalBytesReceived, _source.length))
_destination.write(data, receivedBytes)
}
emitter.onComplete()
}
else {
emitter.onError(IllegalStateException("<${DownloadServiceObservable::class.java}> Source returned with a null value."))
}
}
catch(ex: InterruptedException) {
emitter.onError(ex)
}
finally {
input?.close()
}
})
}
public data class DownloadProgress(val receivedLength: Int, val totalLength: Int)
}
最后，这是我写的测试：
@RunWith(MockitoJUnitRunner::class)
public class DownloadServiceObservableTests
{
@Rule
private val testSchedulerRule = RxImmediateSchedulerRule()
@Test
public fun When_input_is_read__from_source_it_should_match_the_written_output()
{
val source = mock(StreamFactory::class.java)
val destination = mock(StreamWriter::class.java)
val expectedText = "Lorem ipsum dolor sit amet, consectetuer adipiscing elit. Aenean commodo ligula eget dolor. Aenean massa. Cum sociis natoque penatibus et magnis dis parturient montes, nascetur ridiculus mus. Donec quam felis, ultricies nec, pellentesque eu, pretium quis, sem. Nulla consequat massa quis enim. Donec pede justo, fringilla vel, aliquet nec, vulputate eget, arcu. In enim justo, rhoncus ut, imperdiet a, venenatis vitae, justo. Nullam dictum felis eu pede mollis pretium. Integer tincidunt. Cras dapibus. Vivamus elementum semper nisi. Aenean vulputate eleifend tellus. Aenean leo ligula, porttitor eu, consequat vitae, eleifend ac, enim. Aliquam lorem ante, dapibus in, viverra quis, feugiat a, tellus. Phasellus viverra nulla ut metus varius laoreet.\n" + "\n" + "Quisque rutrum. Aenean imperdiet. Etiam ultricies nisi vel augue. Curabitur ullamcorper ultricies nisi. Nam eget dui. Etiam rhoncus. Maecenas tempus, tellus eget condimentum rhoncus, sem quam semper libero, sit amet adipiscing sem neque sed ipsum. Nam quam nunc, blandit vel, luctus pulvinar, hendrerit id, lorem. Maecenas nec odio et ante tincidunt tempus. Donec vitae sapien ut libero venenatis faucibus. Nullam quis ante. Etiam sit amet orci eget eros faucibus tincidunt. Duis leo. Sed fringilla mauris sit amet nibh. Donec sodales sagittis magna. Sed consequat, leo eget bibendum sodales, augue velit cursus nunc, quis gravida magna mi a libero. Fusce vulputate eleifend sapien.\n" + "\n" + "Vestibulum purus quam, scelerisque ut, mollis sed, nonummy id, metus. Nullam accumsan lorem in dui. Cras ultricies mi eu turpis hendrerit fringilla. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; In ac dui quis mi consectetuer lacinia. Nam pretium turpis et arcu. Duis arcu tortor, suscipit eget, imperdiet nec, imperdiet iaculis, ipsum. Sed aliquam ultrices mauris. Integer ante arcu, accumsan a, consectetuer eget, posuere ut, mauris. Praesent adipiscing. Phasellus ullamcorper ipsum rutrum nunc. Nunc nonummy metus. Vestibulum volutpat pretium libero. Cras id dui. Aenean ut eros et nisl sagittis vestibulum. Nullam nulla eros, ultricies sit amet, nonummy id, imperdiet feugiat, pede. Sed lectus.\n" + "\n" + "Donec mollis hendrerit risus. Phasellus nec sem in justo pellentesque facilisis. Etiam imperdiet imperdiet orci. Nunc nec neque. Phasellus leo dolor, tempus non, auctor et, hendrerit quis, nisi. Curabitur ligula sapien, tincidunt non, euismod vitae, posuere imperdiet, leo. Maecenas malesuada. Praesent congue erat at massa. Sed cursus turpis vitae tortor. Donec posuere vulputate arcu. Phasellus accumsan cursus velit. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; Sed aliquam, nisi quis porttitor congue, elit erat euismod orci, ac placerat dolor lectus quis orci. Phasellus consectetuer vestibulum elit. Aenean tellus metus, bibendum sed, posuere ac, mattis non, nunc. Vestibulum fringilla pede sit amet augue.\n" + "\n" + "In turpis. Pellentesque posuere. Praesent turpis. Aenean posuere, tortor sed cursus feugiat, nunc augue blandit nunc, eu sollicitudin urna dolor sagittis lacus. Donec elit libero, sodales nec, volutpat a, suscipit non, turpis. Nullam sagittis. Suspendisse pulvinar, augue ac venenatis condimentum, sem libero volutpat nibh, nec pellentesque velit pede quis nunc. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; Fusce id purus. Ut varius tincidunt libero. Phasellus dolor. Maecenas vestibulum mollis diam. Pellentesque ut neque. Pellentesque habitant morbi tristique senectus et netus et malesuada fames ac turpis egestas. In dui magna, posuere eget, vestibulum et, tempor auctor, justo.\n" + "\n" + "In ac felis quis tortor malesuada pretium. Pellentesque auctor neque nec urna. Proin sapien ipsum, porta a, auctor quis, euismod ut, mi. Aenean viverra rhoncus pede. Pellentesque habitant morbi tristique senectus et netus et malesuada fames ac turpis egestas. Ut non enim eleifend felis pretium feugiat. Vivamus quis mi. Phasellus a est. Phasellus magna. In hac habitasse platea dictumst. Curabitur at lacus ac velit ornare lobortis. Curabitur a felis in nunc fringilla tristique. Morbi mattis ullamcorper velit. Phasellus gravida semper nisi. Nullam vel sem. Pellentesque libero tortor, tincidunt et, tincidunt eget, semper nec, quam. Sed hendrerit. Morbi ac felis. Nunc egestas, augue at pellentesque laoreet, felis eros vehicula leo, at malesuada velit leo quis pede.\n" + "\n" + "Donec interdum, metus et hendrerit aliquet, dolor diam sagittis ligula, eget egestas libero turpis vel mi. Nunc nulla. Fusce risus nisl, viverra et, tempor et, pretium in, sapien. Donec venenatis vulputate lorem. Morbi nec metus. Phasellus blandit leo ut odio. Maecenas ullamcorper, dui et placerat feugiat, eros pede varius nisi, condimentum viverra felis nunc et lorem. Sed magna purus, fermentum eu, tincidunt eu, varius ut, felis. In auctor lobortis lacus. Quisque libero metus, condimentum nec, tempor a, commodo mollis, magna. Vestibulum ullamcorper mauris at ligula. Fusce fermentum. Nullam cursus lacinia erat. Praesent blandit laoreet nibh. Fusce convallis metus id felis luctus adipiscing.\n" + "\n" + "Pellentesque egestas, neque sit amet convallis pulvinar, justo nulla eleifend augue, ac auctor orci leo non est. Quisque id mi. Ut tincidunt tincidunt erat. Etiam feugiat lorem non metus. Vestibulum dapibus nunc ac augue. Curabitur vestibulum aliquam leo. Praesent egestas neque eu enim. In hac habitasse platea dictumst. Fusce a quam. Etiam ut purus mattis mauris sodales aliquam. Curabitur nisi. Quisque malesuada placerat nisl. Nam ipsum risus, rutrum vitae, vestibulum eu, molestie vel, lacus. Sed augue ipsum, egestas nec, vestibulum et, malesuada adipiscing, dui. Vestibulum facilisis, purus nec pulvinar iaculis, ligula mi congue nunc, vitae euismod ligula urna in dolor. Mauris sollicitudin fermentum libero. Praesent nonummy mi in odio.\n" + "\n" + "Nunc interdum lacus sit amet orci. Vestibulum rutrum, mi nec elementum vehicula, eros quam gravida nisl, id fringilla neque ante vel mi. Morbi mollis tellus ac sapien. Phasellus volutpat, metus eget egestas mollis, lacus lacus blandit dui, id egestas quam mauris ut lacus. Fusce vel dui. Sed in libero ut nibh placerat accumsan. Proin faucibus arcu quis ante. In consectetuer turpis ut velit. Nulla sit amet est. Praesent metus tellus, elementum eu, semper a, adipiscing nec, purus. Cras risus ipsum, faucibus ut, ullamcorper id, varius ac, leo. Suspendisse feugiat. Suspendisse enim turpis, dictum sed, iaculis a, condimentum nec, nisi. Praesent nec nisl a purus blandit viverra. Praesent ac massa at ligula laoreet iaculis. Nulla neque dolor, sagittis eget, iaculis quis, molestie non, velit.\n" + "\n" + "Mauris turpis nunc, blandit et, volutpat molestie, porta ut, ligula. Fusce pharetra convallis urna. Quisque ut nisi. Donec mi odio, faucibus at, scelerisque quis, convallis in, nisi. Suspendisse non nisl sit amet velit hendrerit rutrum. Ut leo. Ut a nisl id ante tempus hendrerit. Proin pretium, leo ac pellentesque mollis, felis nunc ultrices eros, sed gravida augue augue mollis justo. Suspendisse eu ligula. Nulla facilisi. Donec id justo. Praesent porttitor, nulla vitae posuere iaculis, arcu nisl dignissim dolor, a pretium mi sem ut ipsum. Curabitur suscipit suscipit tellus. Praesent vestibulum dapibus nibh. Etiam iaculis nunc ac metus. Ut id nisl quis enim dignissim sagittis. Etiam sollicitudin, ipsum eu pulvinar rutrum, tellus ipsum laoreet sapien, quis venenatis ante odio sit amet eros. Proin magna. Duis vel nibh at velit scelerisque suscipit. Curabitur turpis. Vestibulum suscipit nulla quis orci. Fusce ac felis sit amet ligula pharetra condimentum. Maecenas egestas arcu quis ligula mattis placerat. Duis lobortis massa imperdiet quam. Suspendisse potenti. Pellentesque commodo eros a enim. Vestibulum turpis sem, aliquet eget, lobortis pellentesque, rutrum eu, nisl. Sed libero. Aliquam erat volutpat. Etiam vitae tortor. Morbi vestibulum volutpat enim. Aliquam eu nunc. Nunc sed turpis. Sed mollis, eros et ult"
val expectedInput = ByteArrayInputStream(expectedText.toByteArray(StandardCharsets.UTF_8))
val actualOutput = ByteArrayOutputStream()
var actualText = ""
`when`(source.create()).thenReturn(expectedInput)
`when`(destination.write(KotlinArgumentMatchers.nonNullableAny<ByteArray>(), ArgumentMatchers.anyInt())).thenAnswer{
actualOutput.write(it.getArgument(0), 0, it.getArgument(1))
}
DownloadServiceObservable(source, destination)
.download()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe()
actualText = String(actualOutput.toByteArray(), StandardCharsets.UTF_8)
assertThat(actualText, `is`(expectedText))
}
}
我想做的是解耦文件的下载方式与我将文件保存到存储的方式。
正常运行的代码：
以下代码从远程下载一个文件，最后保存到存储中。
private fun downloadFile(url: URL): Observable<Int> {
return Observable.create(fun(emitter)
{
var input: InputStream? = null
var output: OutputStream? = null
var connection: HttpURLConnection? = null
val path = Environment.getExternalStorageDirectory().path
try
{
connection = url.openConnection() as HttpURLConnection
if (connection != null)
{
connection.connect()
if (connection.responseCode != HttpURLConnection.HTTP_OK)
{
emitter.onError(IllegalStateException("<HTTP Error> ${connection.responseMessage}. Status code: ${connection.responseCode}."))
return
}
if (connection.contentType == null)
{
emitter.onError(IllegalStateException("<HTTP Error> Unsupported content-type."))
return
}
val fileLength = connection.contentLength
var fileext = MimeTypeMap.getSingleton().getExtensionFromMimeType(connection.contentType)
input = connection.inputStream
output = FileOutputStream("/$path/SmartTVMediaTest.$fileext")
val data = ByteArray(4096)
var totalBytesReceived: Int = 0
while (!emitter.isDisposed)
{
val receivedBytes: Int = input.read(data)
if (receivedBytes < 0)
{
break
}
totalBytesReceived += receivedBytes
if (fileLength > 0)
{
val portion = totalBytesReceived / fileLength.toFloat()
val percentage = portion * 100
emitter.onNext(percentage.toInt())
Log.d(TAG, "<downloadFile> $fileLength, $totalBytesReceived, $percentage")
}
output.write(data, 0, receivedBytes)
}
emitter.onComplete()
}
else {
emitter.onError(IllegalStateException("<HTTP Connection Error> Unsupported connection type."))
}
}
catch(ex: InterruptedException) {
Log.d(TAG, "<Thread> Download cancelled.")
}
catch (ex: IOException)
{
emitter.onError(ex)
}
finally
{
input?.close()
output?.close()
connection?.disconnect()
}
})
}
无效的代码：
所以我开始创建一个 class 来表示从远程读取的数据块，如下所示：
public data class DownloadChunk(val data: ByteArray, val length: Int, val totalLength: Int)
然后我创建了下载文件的可观察对象，如下所示：
public class DownloadServiceObservable
{
public fun download(url: URL): Observable<DownloadChunk>
{
return Observable.create(fun(emitter)
{
var input: InputStream? = null
var connection: HttpURLConnection? = null
try
{
connection = url.openConnection() as HttpURLConnection
if (connection != null)
{
connection.connect()
if (connection.responseCode != HttpURLConnection.HTTP_OK)
{
emitter.onError(IllegalStateException("<HTTP Error> ${connection.responseMessage}. Status code: ${connection.responseCode}."))
return
}
if (connection.contentType == null)
{
emitter.onError(IllegalStateException("<HTTP Error> Unsupported content-type."))
return
}
val totalLength = connection.contentLength
input = connection.inputStream
val data = ByteArray(4096)
while (!emitter.isDisposed)
{
val length: Int = input.read(data)
if (length < 0)
{
break
}
emitter.onNext(DownloadChunk(data, length, totalLength))
}
emitter.onComplete()
}
else
{
emitter.onError(IllegalStateException("<HTTP Connection Error> Unsupported connection type."))
}
}
catch(ex: InterruptedException)
{
emitter.onError(ex)
}
finally
{
input?.close()
connection?.disconnect()
}
})
}
}
最后，我创建了一个 Observer 将文件保存到设备，如下所示：
public class DownloadFileObserver: Observer<DownloadChunk>
{
private val _file: OutputStream
public override fun onSubscribe(d: Disposable)
{
}
public constructor(path: String)
{
_file = FileOutputStream(path)
}
public override fun onNext(chunk: DownloadChunk)
{
_file.write(chunk.data, 0, chunk.length)
}
public override fun onError(e: Throwable)
{
_file.close()
}
public override fun onComplete()
{
_file.close()
}
}
问题：
DownloadFileObserver 创建的文件已损坏，所以我的第一个假设是在推送和接收项目之间不能保证 onNext 的顺序，但据我所知是，我通过在 observable 中添加一个计数器来测试它，并在观察者中打印计数器。
我想我错过了什么。
您需要测试您的代码，正如您所知，试图检查代码以查看错误只是一种挫败感。
首先，测试您的观察者（用 Java 编写的代码，对于 JUnit 4，抱歉）：
@Test
public void testObserver() {
DownloadFileObserver uut = new DownloadFileObserver("testpath.txt");
bytes[] testData = "Test String".getBytes();
uut.onNext( new DownloadChunk( testData, testData.length, testData.length );
uut.onComplete();
// inspect the result
bytes[] resultData = Files.readAllBytes( Paths.get( "testpath.txt" );
assertTrue( Arrays.equals( testData, resultData );
}
然后开始添加处理多个块的测试，然后是错误。
最后，为您的 DownloadServiceObservable 编写单元测试。这些将更加困难，因为您将需要模拟实际的网络调用。
我设法通过测试重现了这个问题，这是一个线程问题，我订阅并观察了两个不同的线程，所以我读取和写入数据的顺序不同步，所以我最终重构了 DownloadServiceObservable 现在它需要一个 StreamFactory 的实例来处理从给定源获取流以及 StreamWriter 的实例负责将数据写入给定的目的地所以现在所有工作都在后台完成。
澄清一下 StreamFactory 和 StreamWriter 是我创建的两个接口。
现在，DownloadServiceObservable 看起来像这样：
public class DownloadServiceObservable
{
private val _source: StreamFactory
private val _destination: StreamWriter
public constructor(source: StreamFactory, destination: StreamWriter)
{
_source = source
_destination = destination
}
public fun download(): Observable<DownloadProgress>
{
return Observable.create(fun(emitter)
{
var input: InputStream? = null
try {
input = _source.create()
if (input != null) {
val data = ByteArray(4096)
var totalBytesReceived = 0
while (!emitter.isDisposed) {
val receivedBytes: Int = input.read(data)
if (receivedBytes < 0) {
break
}
totalBytesReceived += receivedBytes
emitter.onNext(DownloadProgress(totalBytesReceived, _source.length))
_destination.write(data, receivedBytes)
}
emitter.onComplete()
}
else {
emitter.onError(IllegalStateException("<${DownloadServiceObservable::class.java}> Source returned with a null value."))
}
}
catch(ex: InterruptedException) {
emitter.onError(ex)
}
finally {
input?.close()
}
})
}
public data class DownloadProgress(val receivedLength: Int, val totalLength: Int)
}
最后，这是我写的测试：
@RunWith(MockitoJUnitRunner::class)
public class DownloadServiceObservableTests
{
@Rule
private val testSchedulerRule = RxImmediateSchedulerRule()
@Test
public fun When_input_is_read__from_source_it_should_match_the_written_output()
{
val source = mock(StreamFactory::class.java)
val destination = mock(StreamWriter::class.java)
val expectedText = "Lorem ipsum dolor sit amet, consectetuer adipiscing elit. Aenean commodo ligula eget dolor. Aenean massa. Cum sociis natoque penatibus et magnis dis parturient montes, nascetur ridiculus mus. Donec quam felis, ultricies nec, pellentesque eu, pretium quis, sem. Nulla consequat massa quis enim. Donec pede justo, fringilla vel, aliquet nec, vulputate eget, arcu. In enim justo, rhoncus ut, imperdiet a, venenatis vitae, justo. Nullam dictum felis eu pede mollis pretium. Integer tincidunt. Cras dapibus. Vivamus elementum semper nisi. Aenean vulputate eleifend tellus. Aenean leo ligula, porttitor eu, consequat vitae, eleifend ac, enim. Aliquam lorem ante, dapibus in, viverra quis, feugiat a, tellus. Phasellus viverra nulla ut metus varius laoreet.\n" + "\n" + "Quisque rutrum. Aenean imperdiet. Etiam ultricies nisi vel augue. Curabitur ullamcorper ultricies nisi. Nam eget dui. Etiam rhoncus. Maecenas tempus, tellus eget condimentum rhoncus, sem quam semper libero, sit amet adipiscing sem neque sed ipsum. Nam quam nunc, blandit vel, luctus pulvinar, hendrerit id, lorem. Maecenas nec odio et ante tincidunt tempus. Donec vitae sapien ut libero venenatis faucibus. Nullam quis ante. Etiam sit amet orci eget eros faucibus tincidunt. Duis leo. Sed fringilla mauris sit amet nibh. Donec sodales sagittis magna. Sed consequat, leo eget bibendum sodales, augue velit cursus nunc, quis gravida magna mi a libero. Fusce vulputate eleifend sapien.\n" + "\n" + "Vestibulum purus quam, scelerisque ut, mollis sed, nonummy id, metus. Nullam accumsan lorem in dui. Cras ultricies mi eu turpis hendrerit fringilla. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; In ac dui quis mi consectetuer lacinia. Nam pretium turpis et arcu. Duis arcu tortor, suscipit eget, imperdiet nec, imperdiet iaculis, ipsum. Sed aliquam ultrices mauris. Integer ante arcu, accumsan a, consectetuer eget, posuere ut, mauris. Praesent adipiscing. Phasellus ullamcorper ipsum rutrum nunc. Nunc nonummy metus. Vestibulum volutpat pretium libero. Cras id dui. Aenean ut eros et nisl sagittis vestibulum. Nullam nulla eros, ultricies sit amet, nonummy id, imperdiet feugiat, pede. Sed lectus.\n" + "\n" + "Donec mollis hendrerit risus. Phasellus nec sem in justo pellentesque facilisis. Etiam imperdiet imperdiet orci. Nunc nec neque. Phasellus leo dolor, tempus non, auctor et, hendrerit quis, nisi. Curabitur ligula sapien, tincidunt non, euismod vitae, posuere imperdiet, leo. Maecenas malesuada. Praesent congue erat at massa. Sed cursus turpis vitae tortor. Donec posuere vulputate arcu. Phasellus accumsan cursus velit. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; Sed aliquam, nisi quis porttitor congue, elit erat euismod orci, ac placerat dolor lectus quis orci. Phasellus consectetuer vestibulum elit. Aenean tellus metus, bibendum sed, posuere ac, mattis non, nunc. Vestibulum fringilla pede sit amet augue.\n" + "\n" + "In turpis. Pellentesque posuere. Praesent turpis. Aenean posuere, tortor sed cursus feugiat, nunc augue blandit nunc, eu sollicitudin urna dolor sagittis lacus. Donec elit libero, sodales nec, volutpat a, suscipit non, turpis. Nullam sagittis. Suspendisse pulvinar, augue ac venenatis condimentum, sem libero volutpat nibh, nec pellentesque velit pede quis nunc. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae; Fusce id purus. Ut varius tincidunt libero. Phasellus dolor. Maecenas vestibulum mollis diam. Pellentesque ut neque. Pellentesque habitant morbi tristique senectus et netus et malesuada fames ac turpis egestas. In dui magna, posuere eget, vestibulum et, tempor auctor, justo.\n" + "\n" + "In ac felis quis tortor malesuada pretium. Pellentesque auctor neque nec urna. Proin sapien ipsum, porta a, auctor quis, euismod ut, mi. Aenean viverra rhoncus pede. Pellentesque habitant morbi tristique senectus et netus et malesuada fames ac turpis egestas. Ut non enim eleifend felis pretium feugiat. Vivamus quis mi. Phasellus a est. Phasellus magna. In hac habitasse platea dictumst. Curabitur at lacus ac velit ornare lobortis. Curabitur a felis in nunc fringilla tristique. Morbi mattis ullamcorper velit. Phasellus gravida semper nisi. Nullam vel sem. Pellentesque libero tortor, tincidunt et, tincidunt eget, semper nec, quam. Sed hendrerit. Morbi ac felis. Nunc egestas, augue at pellentesque laoreet, felis eros vehicula leo, at malesuada velit leo quis pede.\n" + "\n" + "Donec interdum, metus et hendrerit aliquet, dolor diam sagittis ligula, eget egestas libero turpis vel mi. Nunc nulla. Fusce risus nisl, viverra et, tempor et, pretium in, sapien. Donec venenatis vulputate lorem. Morbi nec metus. Phasellus blandit leo ut odio. Maecenas ullamcorper, dui et placerat feugiat, eros pede varius nisi, condimentum viverra felis nunc et lorem. Sed magna purus, fermentum eu, tincidunt eu, varius ut, felis. In auctor lobortis lacus. Quisque libero metus, condimentum nec, tempor a, commodo mollis, magna. Vestibulum ullamcorper mauris at ligula. Fusce fermentum. Nullam cursus lacinia erat. Praesent blandit laoreet nibh. Fusce convallis metus id felis luctus adipiscing.\n" + "\n" + "Pellentesque egestas, neque sit amet convallis pulvinar, justo nulla eleifend augue, ac auctor orci leo non est. Quisque id mi. Ut tincidunt tincidunt erat. Etiam feugiat lorem non metus. Vestibulum dapibus nunc ac augue. Curabitur vestibulum aliquam leo. Praesent egestas neque eu enim. In hac habitasse platea dictumst. Fusce a quam. Etiam ut purus mattis mauris sodales aliquam. Curabitur nisi. Quisque malesuada placerat nisl. Nam ipsum risus, rutrum vitae, vestibulum eu, molestie vel, lacus. Sed augue ipsum, egestas nec, vestibulum et, malesuada adipiscing, dui. Vestibulum facilisis, purus nec pulvinar iaculis, ligula mi congue nunc, vitae euismod ligula urna in dolor. Mauris sollicitudin fermentum libero. Praesent nonummy mi in odio.\n" + "\n" + "Nunc interdum lacus sit amet orci. Vestibulum rutrum, mi nec elementum vehicula, eros quam gravida nisl, id fringilla neque ante vel mi. Morbi mollis tellus ac sapien. Phasellus volutpat, metus eget egestas mollis, lacus lacus blandit dui, id egestas quam mauris ut lacus. Fusce vel dui. Sed in libero ut nibh placerat accumsan. Proin faucibus arcu quis ante. In consectetuer turpis ut velit. Nulla sit amet est. Praesent metus tellus, elementum eu, semper a, adipiscing nec, purus. Cras risus ipsum, faucibus ut, ullamcorper id, varius ac, leo. Suspendisse feugiat. Suspendisse enim turpis, dictum sed, iaculis a, condimentum nec, nisi. Praesent nec nisl a purus blandit viverra. Praesent ac massa at ligula laoreet iaculis. Nulla neque dolor, sagittis eget, iaculis quis, molestie non, velit.\n" + "\n" + "Mauris turpis nunc, blandit et, volutpat molestie, porta ut, ligula. Fusce pharetra convallis urna. Quisque ut nisi. Donec mi odio, faucibus at, scelerisque quis, convallis in, nisi. Suspendisse non nisl sit amet velit hendrerit rutrum. Ut leo. Ut a nisl id ante tempus hendrerit. Proin pretium, leo ac pellentesque mollis, felis nunc ultrices eros, sed gravida augue augue mollis justo. Suspendisse eu ligula. Nulla facilisi. Donec id justo. Praesent porttitor, nulla vitae posuere iaculis, arcu nisl dignissim dolor, a pretium mi sem ut ipsum. Curabitur suscipit suscipit tellus. Praesent vestibulum dapibus nibh. Etiam iaculis nunc ac metus. Ut id nisl quis enim dignissim sagittis. Etiam sollicitudin, ipsum eu pulvinar rutrum, tellus ipsum laoreet sapien, quis venenatis ante odio sit amet eros. Proin magna. Duis vel nibh at velit scelerisque suscipit. Curabitur turpis. Vestibulum suscipit nulla quis orci. Fusce ac felis sit amet ligula pharetra condimentum. Maecenas egestas arcu quis ligula mattis placerat. Duis lobortis massa imperdiet quam. Suspendisse potenti. Pellentesque commodo eros a enim. Vestibulum turpis sem, aliquet eget, lobortis pellentesque, rutrum eu, nisl. Sed libero. Aliquam erat volutpat. Etiam vitae tortor. Morbi vestibulum volutpat enim. Aliquam eu nunc. Nunc sed turpis. Sed mollis, eros et ult"
val expectedInput = ByteArrayInputStream(expectedText.toByteArray(StandardCharsets.UTF_8))
val actualOutput = ByteArrayOutputStream()
var actualText = ""
`when`(source.create()).thenReturn(expectedInput)
`when`(destination.write(KotlinArgumentMatchers.nonNullableAny<ByteArray>(), ArgumentMatchers.anyInt())).thenAnswer{
actualOutput.write(it.getArgument(0), 0, it.getArgument(1))
}
DownloadServiceObservable(source, destination)
.download()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe()
actualText = String(actualOutput.toByteArray(), StandardCharsets.UTF_8)
assertThat(actualText, `is`(expectedText))
}
}