leeoades

{
  "meta": {
    "theme": "stackoverflow"
  },
  "$schema": "https://raw.githubusercontent.com/jsonresume/resume-schema/v1.0.0/schema.json",
  "basics": {
    "name": "Lee Oades",
    "label": "Senior Software Developer",
    "image": "https://avatars2.githubusercontent.com/u/2321091?s=800",
    "email": "[email protected]",

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;