ひよっこゲームブログ

なにもかも初心者のひよっこがゆったりと何かする

リアクティブプログラミング４日目

プログラミング

Javaエアプなのでちょくちょく調べないとあかん


サンプルコード

import io.reactivex.rxjava3.schedulers.Schedulers;

Flowable.fromCallable(() -> {
    Thread.sleep(1000); //  imitate expensive computation
    return "Done";
})
  .subscribeOn(Schedulers.io())
  .observeOn(Schedulers.single())
  .subscribe(System.out::println, Throwable::printStackTrace);

Thread.sleep(2000); // <--- wait for the flow to finish


fromCallable()って何
Callable (Java Platform SE 8)

Javaの関数型のインターフェースだそうだ、ほーん


書き直すとこうなるらしい

Flowable<String> source = Flowable.fromCallable(() -> {
    Thread.sleep(1000); //  imitate expensive computation
    return "Done";
});

Flowable<String> runBackground = source.subscribeOn(Schedulers.io());

Flowable<String> showForeground = runBackground.observeOn(Schedulers.single());

showForeground.subscribe(System.out::println, Throwable::printStackTrace);

Thread.sleep(2000);

バックグランドで入出力処理して、そのあとフォアグラウンドで処理してる。うむ


Schedulers

Schedulers.io() とかは「スケジューラー」と呼ばれる。まんまだな
これでスレッド操作とかするみたい

使用感がCoroutineのDispatchersみたいな感じだと思う（適当）


Javaのメインスレッドが終了した場合、スケジューラーは死ぬそうです。ふむふむ

ぱっと中身を見てみる

  • Schedulers.computation()
    バックグラウンドの固定のスレッド。ほとんどの処理はこれがデフォでいいみたい

  • Schedulers.io()
    動的なスレッド。ブロックできると書いてあるので処理待ちができるんだろう、たぶん

  • Schedulers.single()
    単一のスレッドで、FIFO方式（最初に入れたデータを最初に取り出す）

  • Schedulers.trampoline()
    テスト用。これもFIFO方式だそうです。まぁテスト用だし使わんやろ！（


明日を乗り切れば休みだー。リモートになってから曜日感覚がない

リアクティブプログラミング３日目

プログラミング

この勉強方法向いている気がした

今日もRxJavaのリファレンスを上から和訳して読んでく


用語

Upstream, downstream
データフローの種類っぽい
Operatorから見てどの方向にデータがストリームしているかという意味でのUp, down？

実際に動作を確認しないとちょっとこれ分からないです・・・


Objects in motion
emission, emits, item, event, signal, data and message（原文）は同じ意味
データフローで動くオブジェクトって呼ぶ


Backpressure
FlowableとObservableの話でやったやつ
ストリームとして受け取ったデータが重すぎると上手く動かなくなるので、そのための制御フロー


Assembly time
データフローの準備はアセンブラの時間で行われる
コンパイル後に初めて行われるってことだよね・・・？


Subscription time
subscribeが動き始めたときの話だから気にしなくていいや


Runtime
フローがアイテムを放出、エラー、完了したとき
サンプルコード

Observable.create(emitter -> {
     while (!emitter.isDisposed()) {
         long time = System.currentTimeMillis();
         emitter.onNext(time);
         if (time % 2 != 0) {
             emitter.onError(new IllegalStateException("Odd millisecond!"));
             break;
         }
     }
})
.subscribe(System.out::println, Throwable::printStackTrace);

うん、まぁ、そうだな

用語だけで終わってしまった
明日からはまた処理をごたごた見ていく

リアクティブプログラミング２日目

プログラミング

ひとまずRxJavaのリファレンスを読んでみる
いつもの

package rxjava.examples;

import io.reactivex.rxjava3.core.*;

public class HelloWorld {
    public static void main(String[] args) {
        Flowable.just("Hello world").subscribe(System.out::println);
    }
}

データを突っ込んで渡して出力、以上！ Rxをコードに組み込むのが目的のコードなやつ


RxJavaのおおざっぱな流れとしてはこうらしい

  • Observableからデータが流れてくる（＝ストリーム）
  • Operator（＝map()やfilter()）を使うとストリームなデータをいじれる（＝flip）
  • subscribe()で処理を開始


onNextとか色々あった気がするけどひとまず後ででいいや


んで、 Flowable.just って何よ

Flowable : ストリームを作る（＝Observable）
just : オブジェクトをOperatorに渡す


FlowableとObservableの何が違うんだ？

  • io.reactivex.rxjava3.core.Flowable: 0..N flows, supporting Reactive-Streams and backpressure
  • io.reactivex.rxjava3.core.Observable: 0..N flows, no backpressure

「Reactive-Streams and backpressure」とな

ストリームとして受け取ったデータが重すぎると上手く動かなくなるので、そのための制御フロー
処理が重くなるやつはこれ使っとけって感じなのかな

調べてみたらObservableによるデータ制御には限界があるらしい

backpressureによる管理は
「処理が１回終わる毎に、次のデータを１つもらう」
というのを確実に行うためのものみたい、ふむふむ


今日はここまで、昨日は遅かったので早く寝るぞ

リアクティブプログラミング１日目

プログラミング

Rxを勉強していく中で、どうせなら基礎の基礎から記事を書いていこうと思った
ちょっとずつでもいいから毎日がんばろう

リアクティブプログラミングはRxKotlinをちょっとかじった
あとはKotlinのObservableは使ったことある程度
（RxというよりはただのObserverパターンだけども）

RxKotlinは公式の記述がちょっと少なくて、リストのやつしか扱ったことがないんですよね
単体をObservableで管理したかったんだけどぱっと見サンプルが無かった
（というかそもそもRx自体がリスト操作がメインっぽい？）

RxKotlinをちまちまやってたんだけど
RxKotlinよりもRxJavaの方が資料が多いのでひとまずそっちでお勉強することにした
えいえいおー！


リアクティブプログラミングとは

色んなとこに書いてあるけど
データのストリーミングしてデータを受け取るたびにアクションを起こす

ようは変化があったときに、変化した順番に物事を処理する...

Androidだと、通信の結果を待ってから画面遷移とか
RoomDBにデータを書き込んでから処理とか

現状はUI絡みのものだとLiveDataとDataBindingで何とかして
通信とかはCoroutineのasync / awaitとかで対応できる
もうこれでよくね

まぁ非同期対策の武器が多いに越したことはないしひとまず使えるようになりたい


リアクティブプログラミングのメリット

従来の書き方よりシンプルになりやすい（らしい）
なんかこればかりは触ってみないと分からんな


ひとまず今日はここまで。遅いし寝よう
RxJavaのコードは明日から記事にする

DataBindingした話

Android プログラミング

読み込み中...（くるくる）

ってやつがやりたくて、DataBinding使ってみました

developer.android.com

twitterアプリの読み込みとかでくるくる回るアレがしたかった




サンプルに書いてあった条件分岐のやつ

android:text="@{String.valueOf(index + 1)}"
    android:visibility="@{age > 13 ? View.GONE : View.VISIBLE}"
    android:transitionName='@{"image_" + id}'

developer.android.com

ProgressBarと一緒に使って、アクションを起こしたらVISIBLEってやったらそれっぽくできた

<data>
    <variable
        name="isShow"
        type="Boolean" />
</data>

(略)
android:visibility="@{isShow ? android.view.View.VISIBLE : android.view.View.GONE}"

たしかこんな感じで書いた


べんり～～～

デバッグ用の端末の話

Android

風邪気味でつらくて何もやる気がないのでせめて記事を書くのです


今年の１月にスマホを買い替えたんですよ
HUAWEI P8lite（古い）からPixel3aにしたんですよ


ドルフロの特異点とアークナイツのため


んで、P8liteをテスト端末にするかぁと思ったんですけど
（いうてもAndroid6.0でもうサポート的にアレだけど）


上手くデバッグできないんですねこれが
んで、他の端末で動作させると上手くいく


HUAWEIのP20だっけな、あれも上手くデバッグログ出なかったんですよね
動作はするんだけどroomのDB確認用のURLが出てこない


確かPure Androidじゃないんだよねー


こういうのどう対処したらいいんだろう
HUAWEI端末だとデバッグが上手くいかない話でした


ドルフロ楽しいねん

GoogleさんのGitHubが便利な話と愚痴の話

Android

ちょっと前に音声認識のコードをゆるゆる書いてた
まぁ詰まってたとこは解決したんだけども

AndroidのJetpackライブラリの１つにLiveDataっていうのがありまして
それを使うとAndroidのライフサイクルに処理が振り回されないんですよ

MVVM使ってどうこうとか
Databindingするにはどうこうとか

これらを使ってあげればそもそもコードで逐一制御しなくていいじゃんと
今更気が付いたんですねこれが

んで、調べてみるてリファレンス読んだけどこれがピンとこない
（もっとViewの操作が複雑な場合とかじゃないと恩恵薄そうではあるけど）

となってたどり着いたのがGoogleさんのGithub

Google I/O で使ってたアプリのプロジェクトファイルをそのまま公開してたんですねこれ

github.com

アーキテクチャの解説箇所に「LiveDataで良くしたんだぜうんぬん」と書いてありまして
これがまぁ参考になりそうなことよ

しかもテストコードもしっかり付属してます



いやぁ助かる








最近まぁなんか色々やろうと気力を振り絞っているのですが
今日は全然身体が言うことをきかなくて断念

今日もジムで運動した後ならなんとかなると思ったんだけどなぁ
ここ年空けてから精神的に疲れてしまっている

多分年末に爆弾置いてかれたせいなんですけど

ひとまず２月の転職ドラフトの登録に間に合わせたいんですよね
１年で身に着いたことが世間でどのくらいの価値になっているのかを知りたい

明らかにまだ色々足りない部分が多いし
上手くいかなくてもそれが分かれば十分だけど
今の会社にいても自分でなんとかやっていく以外に他がないから早めに出たい

今は仕事でコード書いているのが誰のためにやっているのか分からない
「あなたならなんとかしてくれるでしょ？」みたいな振り方をされてるのが結構きつい

自分のやっていることが正しく「価値として届いているのか」分からない

もうちょっとアウトプットして、みんなに何やってるか伝えたいんだけど
とっとと仕事片づけて帰ってきても疲れてるんすよね

ゲームもなんか上手く楽しめないし

友人と接することだけが心の支えになっている

前の鬱病の予兆段階とは全然違うから少し時間を置けば落ち着くと思う


たぶん