badmotorfinger

using System;
using System.Collections.Generic;
using System.Linq.Expressions;
using System.Reflection;

namespace Bleroy.Helpers {
    public static class NotNull {
        public static TProp Get<TSource, TProp>(this TSource source, Expression<Func<TSource, TProp>> property) where TSource : class {
            if (source == null) return default(TProp);
            var current = property.Body;

badmotorfinger

// Only let input Observable fire every 'n' seconds at most
// but unlike Throttle, items fire immediately when they aren't
// rate-limited.
public IObservable<T> RateLimit<T>(this IObservable<T> This, TimeSpan interval, IScheduler scheduler)
{
    var slot = default(IObservable<Unit>);
    var input = This.Publish().RefCount();

    return input.Window(input, _ => {
            if (slot != null) return slot;

badmotorfinger

public static class TestHelpers
{
    public static void ShouldEqualWithDiff(this string actualValue, string expectedValue)
    {
        ShouldEqualWithDiff(actualValue, expectedValue, DiffStyle.Full, Console.Out);
    }

    public static void ShouldEqualWithDiff(this string actualValue, string expectedValue, DiffStyle diffStyle)
    {
        ShouldEqualWithDiff(actualValue, expectedValue, diffStyle, Console.Out);