ericksli
09/20/2017, 4:07 AMdata class Job(
val request: ApiRequest,
val responseType: Class<out ApiResponse>,
val subject: PublishSubject<out ApiResponse>,
val startedAt: Long
)
private val jobs: MutableMap<String, Job> = mutableMapOf()
...
val response = gson.fromJson(jsonObject, job.responseType::class.java)
job.subject.onNext(response)
job.subject.onComplete()
jobs.remove(id)