【IT168技术】Reactive Extension for .Net framework
.Net反应性框架，在之前的.net框架中就已经有了，没想到也被应用到Windows phone7中来了。
程序员为指定异步操作指定回调，或事件处理程序的时候使用反应性编程。在异步操作完成或者事件触发的时候，就会调用方法并作为对该事件的反应。在这个模型中，数据流、异步请求、事件都可以做为可观察序列，并且接收异步消息，并通过LINQ来合成这些序列。
不过在Phone7中，这个框架只有一部分有用，主要用在：filtering events、composing multiple asynchronous web service requests、emulating data streams.
对于目前来说，在模拟器上没有办法测试Accelerometer和Location的API，就是因为得不到数据。现在可以利用这个框架来实现数据模拟了。
模拟Accelerometer数据：
Thread thread = new Thread(StartAccelerometerEmulation);
thread.Start();
am = new Accelerometer();
var aro = Observable.FromEvent
eh => am.ReadingChanged += eh,
eh => am.ReadingChanged -= eh);
try
{
am.Start();
}
catch (AccelerometerFailedException ae)
{
}
void InvokeAccelerometerReadingChanged(Vector3 data)
{
Deployment.Current.Dispatcher.BeginInvoke(() => AccelerometerReadingChanged(data));
}
void AccelerometerReadingChanged(Vector3 data)
{
this.textBlock1.Text = “x: ” + data.X.ToString(“0.00″);
this.textBlock2.Text = ” y: ” + data.Y.ToString(“0.00″);
this.textBlock3.Text = ” z: ” + data.Z.ToString(“0.00″);
}
private void StartAccelerometerEmulation()
{
var emulationDataAsObservable = EmulateAccelerometerReading().ToObservable();
emulationDataAsObservable.Subscribe(args => InvokeAccelerometerReadingChanged(args));
}
static IEnumerable
{
Random random = new Random();
for (double theta = 0; ; theta += .1)
{
Vector3 reading = new Vector3((float)Math.Sin(theta), (float)Math.Cos(theta * 1.1), (float)Math.Sin(theta * .7));
reading.Normalize();
if (random.NextDouble() > .95)
{
reading = new Vector3((float)(random.NextDouble() * 3.0 – 1.5),
(float)(random.NextDouble() * 3.0 – 1.5),
(float)(random.NextDouble() * 3.0 – 1.5));
}
yield return reading;
Thread.Sleep(200);
}
}
