Anton's drafts

Запись событий и анализ

[Test]
public void Subscribe_should_push_3_values_and_complete()
{
var observable = Observable.Create<int>(x =>
{
x.OnNext(1);
x.OnNext(2);
x.OnNext(3);
x.OnCompleted();
return () => { };
});

var testScheduler = new TestScheduler();
var mockObserver = new MockObserver<int>(testScheduler);

observable.Subscribe(mockObserver);

Assert.That(mockObserver[0].Value.Value, Is.EqualTo(1));
Assert.That(mockObserver[0].Value.Kind, Is.EqualTo(NotificationKind.OnNext));

Assert.That(mockObserver[1].Value.Value, Is.EqualTo(2));
Assert.That(mockObserver[1].Value.Kind, Is.EqualTo(NotificationKind.OnNext));

Assert.That(mockObserver[2].Value.Value, Is.EqualTo(3));
Assert.That(mockObserver[2].Value.Kind, Is.EqualTo(NotificationKind.OnNext));

Assert.That(mockObserver[3].Value.Kind, Is.EqualTo(NotificationKind.OnCompleted));
}

• Time - смещение от момента подписки до возникновение события в тиках
• Value - источник события

• Kind - перечисление рода события OnNext/OnError/OnCompleted
• Value - значение, переданное в качестве аргумента события.

[Test]
public void Subscribe_should_push_value_with_delay_and_complete()
{
var testScheduler = new TestScheduler();
var mockObserver = new MockObserver<int>(testScheduler);

var observable = Observable.Return(42);//Answers to basic questions of life, the universe and everything else :)

observable
.Delay(TimeSpan.FromMilliseconds(1), testScheduler)
.Subscribe(mockObserver);

testScheduler.Run();

Assert.That(mockObserver[0].Value.Value, Is.EqualTo(42));
Assert.That(mockObserver[0].Time, Is.EqualTo(10000));//tiks per milliseconds
Assert.That(mockObserver[0].Value.Kind, Is.EqualTo(NotificationKind.OnNext));

Assert.That(mockObserver[1].Value.Kind, Is.EqualTo(NotificationKind.OnCompleted));
}

Планировщик TestScheduler

• Scheduler.Dispatcher выполняет работу в текущем "Dispatcher", без которого не обойтись в приложениях Silverlight и WPF. Другими словами, реализация этого планировщика - это просто делегирование кода в "Dispatcher" (Dispatcher.BeginInvoke(Action)).
• Scheduler.NewThread выполняет работу в новом потоке.
• Scheduler.ThreadPool выполняет работу в пуле потоков.
• Scheduler.TaskPool выполняет работу в пуле задач.
• Scheduler.Immediate немедленно выполняет работу в текущем потоке.
• Scheduler.CurrentThread выполняет работу в текущем потоке. Разница между Immediate в том, что CurrentThread ставит работу в очередь выполнения.
• TestScheduler эмулирует работу планировщика.

1. Выполнение работы подписки (SubscribeOn())
2. Публикация результатов работы (ObserveOn())

var scheduler = new TestScheduler();
var oneMinentsTiks = scheduler.FromTimeSpan(TimeSpan.FromMinutes(1));
var twoMinentsTiks = scheduler.FromTimeSpan(TimeSpan.FromMinutes(2));

scheduler.Schedule(() => Debug.WriteLine("1"), oneMinentsTiks);
scheduler.Schedule(() => Debug.WriteLine("2"), oneMinentsTiks);
scheduler.Schedule(() => Debug.WriteLine("3"), twoMinentsTiks);
scheduler.Schedule(() => Debug.WriteLine("4"), twoMinentsTiks);
Debug.WriteLine("RunTo(oneMinentsTiks)");
scheduler.RunTo(oneMinentsTiks);
Debug.WriteLine("Run()");
scheduler.Run();

/* Output:
RunTo(oneMinentsTiks)
1
2
Run()
3
4
*/

[TestFixture]
public class TestSchedulerTest
{
[Test]
public void Subscrible_should_push_values_for_two_h_with_interval_15_min_and_complete()
{
var scheduler = new TestScheduler();
var pushCollection = Observable.Interval(TimeSpan.FromMinutes(15), scheduler)
.SelectMany(x=> Observable.Return(String.Format("NextData from Server #{0}", x)))
.Take(8);

mockObserver = new MockObserver<string>(scheduler);

pushCollection.Subscribe(mockObserver);
scheduler.Run();
}
}

HotObservable/ColdObservable

[Test]
public void HotObservable_should_push_values_without_subscrible()
{
var scheduler = new TestScheduler();
var mockObserver = new MockObserver<int>(scheduler);

var hotObservable = new HotObservable<int>(scheduler,
new Recorded<Notification<int>>(1, new Notification<int>.OnNext(1)),
new Recorded<Notification<int>>(2, new Notification<int>.OnNext(2)),
new Recorded<Notification<int>>(3, new Notification<int>.OnNext(3)),
new Recorded<Notification<int>>(4, new Notification<int>.OnNext(4)),
new Recorded<Notification<int>>(5, new Notification<int>.OnNext(5)),
new Recorded<Notification<int>>(6, new Notification<int>.OnNext(6)),
new Recorded<Notification<int>>(7, new Notification<int>.OnNext(7)),
new Recorded<Notification<int>>(8, new Notification<int>.OnNext(8)),
new Recorded<Notification<int>>(9, new Notification<int>.OnNext(9)),
new Recorded<Notification<int>>(10, new Notification<int>.OnCompleted())
);

scheduler.RunTo(4);
hotObservable.Subscribe(mockObserver);
scheduler.Run();

Assert.That(mockObserver.Count, Is.EqualTo(6));
Assert.That(mockObserver[0].Time, Is.EqualTo(5));

Assert.That(mockObserver[5].Value.Kind, Is.EqualTo(NotificationKind.OnCompleted));
}

[Test]
public void ColdObservable_should_push_values_upon_subscrible()
{
var scheduler = new TestScheduler();
var mockObserver = new MockObserver<int>(scheduler);

ar hotObservable = new ColdObservable<int>(scheduler,
new Recorded<Notification<int>>(1, new Notification<int>.OnNext(1)),
new Recorded<Notification<int>>(2, new Notification<int>.OnNext(2)),
new Recorded<Notification<int>>(3, new Notification<int>.OnNext(3)),
new Recorded<Notification<int>>(4, new Notification<int>.OnNext(4)),
new Recorded<Notification<int>>(5, new Notification<int>.OnNext(5)),
new Recorded<Notification<int>>(6, new Notification<int>.OnNext(6)),
new Recorded<Notification<int>>(7, new Notification<int>.OnNext(7)),
new Recorded<Notification<int>>(8, new Notification<int>.OnNext(8)),
new Recorded<Notification<int>>(9, new Notification<int>.OnNext(9)),
new Recorded<Notification<int>>(10, new Notification<int>.OnCompleted())
);

scheduler.RunTo(4);
hotObservable.Subscribe(mockObserver);
scheduler.Run();

Assert.That(mockObserver.Count, Is.EqualTo(10));
Assert.That(mockObserver[0].Time, Is.EqualTo(1));

Assert.That(mockObserver[9].Value.Kind, Is.EqualTo(NotificationKind.OnCompleted));
}

public static class TestSchedulerExtensions
{
   public static ColdObservable<T> CreateColdObservable<T>(this TestScheduler scheduler, params Recorded<Notification<T>>[] messages);
   public static HotObservable<T> CreateHotObservable<T>(this TestScheduler scheduler, params Recorded<Notification<T>>[] messages);
}

• Проверка достоверности значений;
• Приоритезация;
• Наследование поведения;
• Совместное использование свойства зависимостей.

Проверка достоверности и коррекция значений

• Приведение
• Проверка
• Обратный вызов

Проверка достоверности

public static readonly DependencyProperty ValueProperty =
   DependencyProperty.Register("Value", typeof (double), typeof (MainWindow),
    new FrameworkPropertyMetadata(0), ValidateValueCallback);

private static bool ValidateValueCallback(object value)
{
 throw new NotImplementedException();
}

Приведения

public static readonly DependencyProperty ValueProperty =
   DependencyProperty.Register("Value", typeof (double), typeof (MainWindow),
    new FrameworkPropertyMetadata(0, PropertyChangedCallback, CoerceValueCallback));

private static object CoerceValueCallback(DependencyObject sender, object baseValue)
{
 throw new NotImplementedException();
}

Обратный вызов

public static readonly DependencyProperty ValueProperty =
   DependencyProperty.Register("Value", typeof (double), typeof (MainWindow),
    new FrameworkPropertyMetadata(0, PropertyChangedCallback, CoerceValueCallback));

private static void PropertyChangedCallback(DependencyObject sender, DependencyPropertyChangedEventArgs args)
{
 throw new NotImplementedException();
}

Приоритезация

1. Анимации. Для достижения желаемого эффекта, анимация должна иметь возможность затереть базовое (не анимированное) значение, даже если значение установлено локально.
2. Локальное значение. Локальные значения присваивается через модель свойств CLR, что приравнивается к присваиванию значения атрибуту в XAML. К данному уровню приоритета относится позднее связывание или ресурсы.
3. Свойства шаблонов. Значения свойств шаблона, если элемент был создан как часть шаблона.(ControlTemplate или DataTemplate).
4. Стили. Значения, которые присваиваются при помощи механизма Setter.
5. Значение по умолчанию. Значение, которое было присвоено свойству при его регистрации.

Наследование поведения

public static readonly DependencyProperty FontSizeProperty =
   DependencyProperty.Register("FontSize", typeof (double), typeof (MainWindow),
    new FrameworkPropertyMetadata(12,FrameworkPropertyMetadataOptions.Inherits));

Совместное использование свойства зависимостей

FontSizeProperty = TextElement.FontSizeProperty.AddOwner(typeof (MainWindow));

Вместо заключения