leeoades

{
  "meta": { "theme": "kendall" },
  "$schema": "https://raw.githubusercontent.com/jsonresume/resume-schema/v1.0.0/schema.json",
  "basics": {
    "name": "Lee Oades",
    "label": "Software Developer and Consultant // Lee Oades Consulting Ltd",
    "image": "https://avatars2.githubusercontent.com/u/2321091?s=800",    
    "email": "lee.oades@gmail.com",
    "phone":"+44 (0)7946 233 130",
    "url": "https://registry.jsonresume.org/leeoades",

leeoades

namespace Stuff
{
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Reactive.Linq;
    using System.Reactive.Subjects;
    using Core.Extensions;
    using Microsoft.Reactive.Testing;
    using NUnit.Framework;

leeoades

public static IObservable<T> Pausable<T>(
           this IObservable<T> sourceStream,
           IObservable<bool> isPausedStream,
           bool startPaused = false)
        {
            return Observable.Create<T>(o =>
            {
                var subscriptions = new SerialDisposable();
                var replaySubjects = new SerialDisposable();

leeoades

using System;
using System.Reactive.Concurrency;
using System.Reactive.Linq;
using System.Reactive.Subjects;

namespace Stuff
{
    public class Cache<T> : IDisposable
    {
        private readonly IConnectableObservable<T> _source;