UnityUniRx学习笔记

Posted 2022-01-31 不如詩啊

【Unity】UniRx学习笔记

教学视频网址: https://www.bilibili.com/video/BV1s7411g72C?from=search&seid=3314917337798091922

UniRx语法格式

Observable.XXX.Subscribe();
翻译:XXX数据流来了之后要做什么事情.

Observable.XXX.Subscribe(
	_ => 
	
		//Do OnNext
	,
	ex => 
	
		//Do OnError
	,
	() => 
	
		//OnComplete
	
);

案例分析1

简单例子

void Start()

	Observable.EveryUpdate().Subscribe(_ => 
	
		print("一帧数据流来了");
	);

结合Linq方法

void Start()
//结合Linq方法
	Observable.EveryUpdate().Where(_ => Input.GetMouseButtonDown(0)).Subscribe(_ => 
	
		print("从每帧数据流中筛选出按下鼠标左键的特定流!");
	);

UniRx操作符:
1: UniRx操作符_自Linq
2: UniRx操作符_自Rx.Net
3: UniRx操作符_UniRx独有

案例分析2

数据流能够嵌套适用

void Start()
//点火型
	var stream1 = Observable.EveryUpdate().Subscribe(_ =>
	//事件流1: 每帧输出1
		print("1");
	);
	var stream2 = Observable.EveryUpdate().Subscribe(_ =>
	
		print("2");
		Observable.Timer(System.TimeSpan.FromSeconds(1)).Subscribe(_ =>
		//等1秒后执行
			stream1.Dispose(); //取消事件流1
		);
	);

案例分析3

数据流合并

void Start()
//合并两个数据流, 相当于"或"操作
	var stream1 = Observable.EveryUpdate().Where(_ => Input.GetMouseButtonDown(0));
	var stream2 = Observable.EveryUpdate().Where(_ => Input.GetMouseButtonDown(1));
	Observable.Merge(stream1, stream2).Subscribe(_ => print("Mouse has clicked!"));

案例分析4

多线程支持

void Start()
//易实现多线程支持
	var threadAStream = Observable.Start(() = > 
	//开启一个线程, 等待一秒后返回1
		System.Threading.Thread.Sleep(TimeSpan.FromSeconds(1));
		return 1;
	);
	var threadBStream = Observable.Start(() = > 
	//开启一个线程, 等待一秒后返回2
		System.Threading.Thread.Sleep(TimeSpan.FromSeconds(3));
		return 2;
	);
	//当两个线程都返回后, 在主线程输出各自的返回值
	Observable.WhenAll(threadAStream, threadBStream)
	.ObserveOnMainThread().Subscribe(xs => 
	
		Debug.Log(xs[0] + ":" + xs[1]);
	);

总结

1. 由 “拉数据” 转变为 “数据推” !
2. 一切都是数据流!
3. 可以灵活地异步处理数据流!