facebook twitter hatena line email

「Unity/R3/UniRxから移植」の版間の差分

提供: 初心者エンジニアの簡易メモ
移動: 案内検索
(ReactiveCollectionをObservableListへ)
(SubjectのSubscribeの置換)
行86: 行86:
 
==SubjectのSubscribeの置換==
 
==SubjectのSubscribeの置換==
 
<pre>
 
<pre>
// R3
+
// 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")
 
             );
 
             );
  
// UniRx
+
// 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)
        () => Debug.Log("Completed")
 
 
             );
 
             );
 
</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)
            );