kotlinx.coroutines

2熱

1答えて

"+"

これはKotlinコルーチンのためCancellation via explicit jobのためのサンプルコードです： fun main(args: Array<String>) = runBlocking<Unit> { val job = Job() // create a job object to manage our lifecycle // now launch

kotlin operator-overloading coroutine kotlinx.coroutines 2017-11-29

---

1熱

1答えて

マルチスレッド使用Kotlinコルーチン

私はKotlin Coroutinesで実験し、次のコードを持っている：ローマElizarovの別のコルーチンにanswer関連の質問によると number of cores: 4 async number:0 on thread ForkJoinPool.commonPool-worker-2 async number:2 on thread ForkJoinPool.commonPool-

multithreading jvm kotlin kotlinx.coroutines 2017-12-01

---

1熱

1答えて

タイムアウトのKotlin Coroutines

私は現在、ブロックを実行するテスト関数を作成しています（または、特定のタイムアウトに達すると例外をスローします）。 私はKotlinでCoroutinesでこれをしようとしたがCoroutinesとCompletableFutureの混合物になってしまった。 fun <T> runBlockWithTimeout(maxTimeout: Long, block:() -> T): T {

kotlin kotlinx.coroutines 2017-12-04

---

1熱

1答えて

`SendChannel.offer`、` CompletableDeferred.complete`などはコルーチンの外で呼び出すことができますか？

CompletableDeferredドキュメントは、このインターフェイス上で、そこから派生したすべてのインターフェイス上 すべての関数はスレッドセーフであり、安全に外部同期せずに同時コルーチンから呼び出すことができると言います。 これらの関数を任意のコルーチンの外部で呼び出すことは安全ですか？ SendChannel<E>については 、offerとcloseはsuspendではありませんので、彼

kotlin coroutine kotlinx.coroutines 2017-12-05

---

0熱

1答えて

俳優がkotlinx.coroutines 0.20で停止するまで最善の方法を教えてください。 kotlinx.coroutines 0.19で

は、join EDになることができactor戻りActorJob：0.20で val myActor = actor<...> { ... } ... myActor.join() は、SendChannelを返すように変更されます。実装を見てみると、それはまだJobを拡張するクラスのインスタンスを返すんので、私は ... (myActor as Job).join() を書くことが

kotlin kotlinx.coroutines 2017-12-05

---

1熱

2答えて

コトリンコルーチンが嚥下する例外

コルーチンで例外処理がどのように機能するのか非常に混乱します。 私は、同期コードのように例外を渡すサスペンド機能の連鎖を持つことができると考えていました。だからRetrofitがIOExceptionを投げたとすると、プレゼンターなどのサスペンド機能のチェーンの始めにその例外を処理して、ユーザーにエラーを表示することができました。 私はコルーチンを試すためにこの簡単な例を作ったが、例外の実行に失敗

android exception kotlin kotlinx.coroutines 2017-12-12

---

3熱

1答えて

プロデューサをアクタに接続するにはどうすればよいですか？

produceコルーチンビルダーで作成したプロデューサをactorコルーチンビルダーで作成したアクターに接続するにはどうすればよいですか？ 基本的には、producerの送信チャンネルをactorの受信チャンネルにしたいと思います。それを行う簡単な方法はありますか？ ドキュメンテーションで、プロデューサまたはアクタが使用するチャネルを明示的に指定できるものが見つかりませんでした。以下の定義を想定し

kotlin actor kotlinx.coroutines 2017-12-13

---

3熱

1答えて

ボタンクリックでランブロックを使用する方法

ランブロックの目的は何ですか？ OnClickListener？で使用できますか？ ここで私はこれが私のコード mBinding.ivAdd.setOnClickListener{ println("before" + Thread.currentThread().id) runBlocking { println("in async" + Thread.current

android kotlin coroutine kotlinx.coroutines 2017-12-20

---

5熱

1答えて

Kotlin：シーケンス（コルーチン）をIterableとして渡す方法<T>

Iterableが必要なところでCoroutineを渡す方法がわかりません。 は、私は次の関数があるとします。 fun <T> iterate(iterable: Iterable<T>) { for (obj in iterable) { // do something.. } } 私はコルーチンを渡したい： iterate(?? { for (o

kotlin kotlinx.coroutines 2017-12-22

---

2熱

1答えて

Kotlin /アンドロイド - ラムダとデータクラスでKotlinReflectionInternalError

kotlin.reflect.jvm.internal.KotlinReflectionInternalError: Introspecting local functions, lambdas, anonymous functions and local variables is not yet fully supported in Kotlin reflection この例外は、データクラスの

exception reflection lambda kotlin kotlinx.coroutines 2017-12-29

---