在保存文件时,调用ForwardingSource的read方法,通过RxBus发送实时的FileLoadEvent对象。FileCallBack订阅RxBus发送的FileLoadEvent。通过接收到FileLoadEvent中的下载进度和文件总大小对UI进行更新。在下载保存文件完成后,取消订阅,防止内存泄漏。RxBus名字看起来像一个库,但它并不是一个库,而是一种模式,它的思想是使用RxJava来实现了EventBus,而让你不再需要使用OTTO或者EventBus。