Запрос Kotlin -Coroutine не будет ждать до завершения первого запроса - PullRequest
Новая
       41

Запрос Kotlin -Coroutine не будет ждать до завершения первого запроса

1 голос
/ 25 июня 2019

У меня есть 2 запроса: SIGNUP и SIGNUP_UPLOAD_AVATAR 

@POST(SIGNUP)
fun registerUser(@QueryMap(encoded = true) userCredentials: HashMap<String, Any>): Deferred<Response<UserResponse>>


@Multipart
@POST(SIGNUP_UPLOAD_AVATAR) //SHOULD BE A PUT, DUE TO ONLY SEND FILE.
fun uploadAvatar(@Part file: MultipartBody.Part): Deferred<Response<ResponseBody>>

В настоящее время я решил изменить для использования COROUTINES , однако у меня возникла проблема, то есть когда первое сообщение SIGNUP_UPLOAD_AVATAR начинает его запрос, мне нужно подождать, пока он не закончится, чтобы перейдите к процессу SIGNUP . Однако вторая сопрограмма запускается немедленно, не спрашивая, завершен ли первый запрос или все еще работает.

Это моя функция: 

fun getImageUrlCoRoutine(){
        val requestFile = RequestBody.create(MediaType.parse("multipart/form-data"), profilePicture)
        val body = MultipartBody.Part.createFormData("file", "android.${getFileExtension(profilePicture)}", requestFile)

        val service = APIService.create()
        val request = service.uploadAvatar(body)
        try {
            GlobalScope.launch(Dispatchers.Main) {
                val response = CoroutineUtil().retryIO (times = 3){ request.await() }
                val responseCode = StatusCode(response.code()).description
                when(responseCode){
                    StatusCode.Status.OK -> {
                        response.body()?.let {
                            it.let {
                                println("RESULT: " + it.string())
                                avatarUrl = it.string()

                                println("Avatar: " + avatarUrl)
                                registrationCoroutine(this)  <- here goes for the second request(registration)
                            }
                        }
                    }
                    else -> {}
                }
            }
        }catch (e: HttpException){
            val responseCode = StatusCode(e.code()).description
            when(responseCode){
                StatusCode.Status.NotAcceptable -> {
                }
                else -> {
                }
            }
        }catch (e: Throwable){
            println("Houston we got a Coroutine Problem")
            println(e)
        }
    }



fun registrationCoroutine(suspended: CoroutineScope) {
        val service = APIService.create()
        val data = HashMap<String, Any>()
        data["email"] = email
        data["phone"] = phoneNumber
        data["username"] = email
        data["password"] = password
        data["fullName"] = fullname
        data["token"] = ""
        data["appName"] = BuildConfig.APP_NAME
        data["avatarUrl"] = avatarUrl
        data["deviceType"] = BuildConfig.PLATFORM
        data["needsVerify"] = false

            suspended.launch {
                val request = service.registerUser(data)
                try {
                    val response = CoroutineUtil().retryIO(times = 3) { request.await() }
                    val responseCode = StatusCode(response.code()).description
                    when(responseCode){
                        StatusCode.Status.OK -> {
                            response.body()?.let {
                                it.let {
                                    println(it)
                                }
                            }
                        }
                        else -> {}
                    }
                } catch (e: HttpException) {
                    val responseCode = StatusCode(e.code()).description
                    when(responseCode){
                        StatusCode.Status.NotAcceptable -> {}
                        else -> {}
                    }
                } catch (e: Throwable) {
                    println("Houston we have a coroutine problem")
                    println(e)
                }
        }
    }

и ответы, которые я получаю ...

2019-06-25 08: 41: 28,858 19886-19886 / com.multirequest.development I / System.out: РЕЗУЛЬТАТ:

2019-06-25 08: 41: 28,859 19886-19886 / com.multirequest.development I / System.out: Аватар:

2019-06-25 08: 41: 28,880 19886-20735 / com.multirequest.development D / OkHttp: -> POST http://myCustomURL.com/signup?deviceType=ANDROID&password=demdemdem&needsVerify=false&phone=+1123456789&avatarUrl=&appName=DEMO&fullName=demmmm&email=demm@gmail.com&username=demm@gmail.com&token= 201

И мне нужно, чтобы, когда я получил AvatarURL, начался процесс регистрации ...

Спасибо:)

...