「Unity/R3/UniRxから移植」の版間の差分
提供: 初心者エンジニアの簡易メモ
(→ReactiveCollectionをObservableListへ) |
(→SubjectのSubscribeの置換) |
||
行86: | 行86: | ||
==SubjectのSubscribeの置換== | ==SubjectのSubscribeの置換== | ||
<pre> | <pre> | ||
− | // | + | // UniRx |
Subject<string> subject = new Subject<string>(); | Subject<string> subject = new Subject<string>(); | ||
subject | subject | ||
行92: | 行92: | ||
message => Debug.Log("msg1:" + message), | message => Debug.Log("msg1:" + message), | ||
error => Debug.LogError("Error" + error) | error => Debug.LogError("Error" + error) | ||
+ | () => Debug.Log("Completed") | ||
); | ); | ||
− | // | + | // R3 |
Subject<string> subject = new Subject<string>(); | Subject<string> subject = new Subject<string>(); | ||
subject | subject | ||
行100: | 行101: | ||
message => Debug.Log("msg1:" + message), | message => Debug.Log("msg1:" + message), | ||
error => Debug.LogError("Error" + error) | error => Debug.LogError("Error" + error) | ||
− | |||
); | ); | ||
</pre> | </pre> |
2024年4月2日 (火) 15:00時点における版
目次
using置換
- using UniRx; + using R3; - using UniRx.Triggers; + using R3.Triggers; - using System;
参考:https://zenn.dev/tkada/articles/a96258e080056a
ObserveEveryValueChangedはEveryValueChangedへ
// UniRx transform.ObserveEveryValueChanged(_ => _.Count).Subscribe(count => Debug.Log(count)); // R3 Observable.EveryValueChanged(transform, _ => _.Count) .Subscribe(count => Debug.Log(count));
参考:https://qiita.com/toRisouP/items/4344fbcba7b7e8d8ce16
Observable.Createの置換
// UniRx IObservable<int> isCompletedsAsObservable = Observable.Create<int>(observer => { return Disposable.Empty; }); // R3 Observable<int> isCompletedsAsObservable = Observable.Create<int>(observer => { return Disposable.Empty; });
IObservableをObservableへ
// UniRx ObservableCollision2DTrigger landTrigger; IObservable<Collision2D> landOnCollisionEnterAsObservable = landTrigger.OnCollisionEnter2DAsObservable(); // R3 ObservableCollision2DTrigger landTrigger; Observable<Collision2D> landOnCollisionEnterAsObservable = landTrigger.OnCollisionEnter2DAsObservable();
Observable.EveryUpdate()~AddTo()の返り値まわり対応
//UniRx var observable = Observable.EveryUpdate() .Subscribe(_ => { }).AddTo(disposable); // R3 Observable.EveryUpdate() .Subscribe(_ => { }).AddTo(disposable);
ReactiveCollectionをObservableList<T>へ
ObservableList では、`using ObservableCollections;`を追加する。
// UniRx private ReactiveCollection<string> users = new ReactiveCollection<string>(); users .ObserveAdd() .Subscribe(value => { Debug.Log($"[Add]Index={value.Index},Value={value.Value}"); }); // R3 using ObservableCollections; private ObservableList<string> users = new ObservableList<string>(); users .ObserveAdd() .Subscribe(value => { Debug.Log($"[Add]Index={value.Index},Value={value.Value}"); });
SubjectのSubscribeの置換
// UniRx Subject<string> subject = new Subject<string>(); subject .Subscribe( message => Debug.Log("msg1:" + message), error => Debug.LogError("Error" + error) () => Debug.Log("Completed") ); // R3 Subject<string> subject = new Subject<string>(); subject .Subscribe( message => Debug.Log("msg1:" + message), error => Debug.LogError("Error" + error) );