問題タブ [reactivex]

Android と Java の開発は初めてです。GitHub からいくつかのサード パーツ ライブラリをインポートしていますが、rx (ReactiveX) パッケージが必要です。ReactiveX からコードをビルドしているときに、パッケージsun.miscが存在しないというエラーが表示されます。rx パッケージはUnsafeこちらを使用しています。

Android Studio のバージョンは 1.5.1 です。Java 1.8.0_73 と 74 の両方を試しましたが、動作しませんでした。ただし、sun.misc.UnsafeWindows の Netbeans 8.1 で Java プロジェクトを作成する場合、問題なくインポートできます。

私のJDKは64ビットです。

インターネットで検索しようとしましたが、答えが見つかりませんでした。助けてください。

私はこのコードを持っています:

指定された通知のいずれかをリッスンし、いずれかがトリガーされたときに処理することになっています。

ただし、これはコンパイルされません。次のエラーが表示されます。

これら2つの信号を1つにマージするにはどうすればよいですか?

次のコードはデータをコンソール ウィンドウに記録せず、例外もスローせず、Transpiler もエラーを表示しません。Angular 2.0.0-beta.7 に取り組んでいます。数時間かかりましたが、解決策がわかりませんでした。

app.component.tsは以下です

index.html

tsconfig.json

パッケージ.json

私は2つのオブザーバブルを持っていaますb. 私はそれらを次のように組み合わせたい：

つまり、bの放出直後の の最初の放出で Observable の結果を放出させたいのですa。

私はreactivex/rxjsを使用していますが、概念的なヒントだけで十分です。前もって感謝します！

この種の質問がすでに寄せられていることは承知しており、回答済みの質問もすべて参照しましたが、それでも問題を解決できませんでした。このエラーは 、これをimport 'rxjs/add/operator/fromArray';除いて展開したときに正確に発生し、コードは問題なく動作します。私はAngular 2.0.0-beta.7を使用していますimportObservable.fromArray

コンソールにスローされるエラー

app.component.ts

index.html

tsconfig.json

パッケージ.json

RxSwift を使用していますが、subscribeNext と bindNext の違いは何ですか?

ご意見ありがとうございます。

http 呼び出しの結果を多くのサブスクライバーと共有するために、リアクティブ プログラミングに依存しようとしています。同時に、コールを再度実行できるようにしたい (リフレッシュ)。

http 呼び出しを実行し、すぐに完了するコールド Observable から始めます。

私はそれをラップして、次のように機能するホットオブザーバブルを取得したいと考えています。すべてのサブスクライバーは、サブスクライブ時に常に最後のイベント (存在する場合) を受信し、サブスクライブが解除されるまで他のすべてのイベントを受信する必要があります。更新をトリガーし、すべてのサブスクライバーで新しいイベントをトリガーする方法 (そのオブザーバブルの外部) が必要です。

詳細:

によってビルドされた http リクエスト用のコールド Observable がありますretrofit2。完全を期すために、これは私のサービスインターフェースです

サービスの改造を依頼します。

サービスからオブザーバブルを取得します。

これはコールドオブザーバブルであり、呼び出されるたびに http 呼び出しを実行しsubscribe()、すぐに完了します。

ホットオブザーバブルを公開したいのですが、これを行うことができると読みました：

このようにして、最初に http 呼び出しが実行され、subscribe()複数回サブスクライブすると、すべてが同じに「接続」されcoldObservableます。

呼び出しが完了した後、subscribe()もう一度呼び出しても何も起こりません。完了へのコールバックもありません。

代わりに、最後のイベントを受け取りたいです。

ユーザーが要求した場合、強制的に更新したい (http 呼び出しを繰り返す)。すべてのサブスクライバーは、新しい結果/エラーを受け取る必要があります。

私は次のようなものを想像します：

トリガーされた更新により、 で新しいイベントが生成されtheSmartObservableます。

そのようなオブザーバブルを構築するにはどうすればよいですか?

そうでない場合は、コメントで教えてください。

それらがさまざまな種類のタスクに使用されるのはなぜですか? 計算タスクと io タスクを処理するときの違いは何ですか?

Schedulers.computation( ) - イベントループやコールバック処理などの計算作業用。このスケジューラーを I/O に使用しないでください (代わりに Schedulers.io( ) を使用してください)。デフォルトでは、スレッドの数はプロセッサの数と同じです

Schedulers.io( ) - ブロッキング I/O の非同期パフォーマンスなど、I/O バウンドの作業用で、このスケジューラは必要に応じて拡張されるスレッドプールによってサポートされます。通常の計算作業の場合は、Schedulers.computation( ); に切り替えます。デフォルトの Schedulers.io( ) は CachedThreadScheduler であり、スレッド キャッシュを備えた新しいスレッド スケジューラのようなものです。