class Program
{
    static void Main(string[] args)
    {
        bool isComplete = false;
        var t = Task.Factory.StartNew(() =>
        {
            bool toggle = false;
            while (!isComplete) // read the cached value
            {

static void Main(string[] args)
{
    var xs = Observable.Interval(TimeSpan.FromSeconds(0.5)).Publish().RefCount();
    var zs = xs.Buffer(xs.Sample(TimeSpan.FromSeconds(1.5)), x => xs.Skip(5).Take(1));
 
    zs.Subscribe(item => Console.WriteLine("{0} - {1}", item.First(), item.Last()));
    Console.ReadKey();
    Task<WebResponse>[] results = GetesourcesAsync(
        new []
        {

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Reactive.Linq;
using System.Reactive.Concurrency;
using System.Reactive.Disposables;
using System.Threading.Tasks;
 
namespace Sela.Samples

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading;
 
namespace TplKeepAlive
{
    class Program

// Map content before registering areas
protected void Application_Start()
{
    Content.Map<MyPortableArea>()
        .Master("~/Views/Shared/PA.master")
        .Title("PATitle")
        .Body("PAMain");
 
    AreaRegistration.RegisterAllAreas();