Network Stetho

MainActivity.kt

// ...
val progressDialog = ProgressDialog(this)
progressDialog.setCancelable(false)
progressDialog.setMessage("Please wait")

button_network.setOnClickListener { _ ->
    progressDialog.show()
    Observable
            .create<Boolean> { emitter ->
                val request = Request.Builder()
                        .url("https://jsonplaceholder.typicode.com/posts")
                        .addHeader("Accept", "application/json")
                        .addHeader("Content-Type", "application/json")
                        .build()
                OkHttpClient.Builder()
                        .addInterceptor(HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY))
                        .addNetworkInterceptor(StethoInterceptor())
                        .build()
                        .newCall(request)
                        .enqueue(object : Callback {
                            override fun onFailure(call: Call, e: IOException) {
                                emitter.onError(e)
                            }

                            override fun onResponse(call: Call, response: Response) {
                                emitter.onNext(true)
                                emitter.onComplete()
                            }
                        })
            }
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(
                    {
                        progressDialog.dismiss()
                    },
                    {
                        progressDialog.dismiss()
                        it.printStackTrace()
                    },
                    {
                        /* nothing to do in here */
                    }
            )
}
// ...