【翻译】忘了RxJava吧——你需要的是拥抱Kotlin协程（Part 1/2）

interface ApiClientRx {

	fun login(auth: Authorization) : Single<GithubUser>
	fun getRepositories(reposUrl: String, auth: Authorization) : Single<List<GithubRepository>>
	fun searchRepositories(query: String) : Single<List<GithubRepository>>

}

private fun attemptLoginRx() {
  val login = email.text.toString()
  val pass = password.text.toString()

  val auth = BasicAuthorization(login, pass)
  val apiClient = ApiClientRx.ApiClientRxImpl()
  showProgressVisible(true)
  compositeDisposable.add(apiClient.login(auth)
	.flatMap {
		user -> apiClient.getRepositories(user.reposUrl, auth)
	}
	.map { list -> list.map { it.fullName } }
	.subscribeOn(Schedulers.io())
	.observeOn(AndroidSchedulers.mainThread())
	.doAfterTerminate { showProgressVisible(false) }
	.subscribe(
			{ list -> showRepositories(this@LoginActivity, list) },
			{ error -> Log.e("TAG", "Failed to show repos", error) }
	))
}

public actual interface Deferred<out T> : Job {
   public suspend fun await(): T
}

interface Job : CoroutineContext.Element {
	public val isActive: Boolean
	public val isCompleted: Boolean
	public val isCancelled: Boolean
	public fun getCancellationException(): CancellationException
	public fun start(): Boolean
}

interface ApiClient {

	fun login(auth: Authorization) : Deferred<GithubUser>
	fun getRepositories(reposUrl: String, auth: Authorization) : Deferred<List<GithubRepository>>

}

override fun login(auth: Authorization) : Deferred<GithubUser?> = async {
	val response = get("https://api.github.com/user", auth = auth)
	if (response.statusCode != 200) {
		throw RuntimeException("Incorrect login or password")
	}

	val jsonObject = response.jsonObject
	with (jsonObject) {
		return@async GithubUser(getString("login"), getInt("id"),
			getString("repos_url"), getString("name"))
	}
}

job = launch(UI) {
	showProgressVisible(true)
	val auth = BasicAuthorization(login, pass)
	try {
		val userInfo = login(auth).await()
		val repoUrl = userInfo.reposUrl
		val repos = getRepositories(repoUrl, auth).await()
		val pullRequests = getPullRequests(repos[0], auth).await()
		showRepositories(this, repos.map { it -> it.fullName })
	} catch (e: RuntimeException) {
		Toast.makeText(this, e.message, LENGTH_LONG).show()
	} finally {
		showProgressVisible(false)
	}
}

@Test
fun login() {
	val apiClientImpl = ApiClientRx.ApiClientRxImpl()
	val genericResponse = mockLoginResponse()

	staticMockk("khttp.KHttp").use {
		every { get("https://api.github.com/user", auth = any()) } returns genericResponse

		val githubUser = apiClientImpl.login(BasicAuthorization("login", "pass"))

		githubUser.subscribe { githubUser ->
			Assert.assertNotNull(githubUser)
			Assert.assertEquals("name", githubUser.name)
			Assert.assertEquals("url", githubUser.reposUrl)
		}
	}
}

@Test
fun login() {
	val apiClientImpl = ApiClient.ApiClientImpl()
	val genericResponse = mockLoginResponse()

	staticMockk("khttp.KHttp").use {
		every { get("https://api.github.com/user", auth = any()) } returns genericResponse

		runBlocking {
			val githubUser = apiClientImpl.login(BasicAuthorization("login", "pass")).await()
				
			assertNotNull(githubUser)
			assertEquals("name", githubUser.name)
			assertEquals("url", githubUser.repos_url)
		}
	}
}

interface SuspendingApiClient {

	suspend fun login(auth: Authorization) : GithubUser
	suspend fun getRepositories(reposUrl: String, auth: Authorization) : List<GithubRepository>
	suspend fun searchRepositories(searchQuery: String) : List<GithubRepository>

}

private fun attemptLoginSuspending() {
	val login = email.text.toString()
	val pass = password.text.toString()
	val apiClient = SuspendingApiClient.SuspendingApiClientImpl()
	job = launch(UI) {
		showProgressVisible(true)
		val auth = BasicAuthorization(login, pass)
		try {
			val userInfo = async(parent = job) { apiClient.login(auth) }.await()
			val repoUrl = userInfo.repos_url
			val list = async(parent = job) { apiClient.getRepositories(reposUrl, auth) }.await()
			showRepositories(this, list.map { it -> it.fullName })
		} catch (e: RuntimeException) {
			Toast.makeText(this, e.message, LENGTH_LONG).show()
		} finally {
			showProgressVisible(false)
		}
	}
}

@Test
fun testLogin() = runBlocking {
	val apiClient = mockk<SuspendingApiClient.SuspendingApiClientImpl>()
	val githubUser = GithubUser("login", 1, "url", "name")
	val repositories = GithubRepository(1, "repos_name", "full_repos_name")

	coEvery { apiClient.login(any()) } returns githubUser
	coEvery { apiClient.getRepositories(any(), any()) } returns repositories.asList()

	val loginPresenterImpl = SuspendingLoginPresenterImpl(apiClient, CommonPool)
	runBlocking {
		val repos = loginPresenterImpl.doLogin("login", "password")
		assertNotNull(repos)
	}
}

given {
	runBlocking {
		apiClient.login(any())
	}
}.willReturn (githubUser)