yreynhout

using System;
using System.Collections.Generic;
using System.Reactive;
using System.Reactive.Subjects;

namespace NaiveEventSourcing {
  class Program {
    static void Main(string[] args) {
      var travelerRepository = new AlwaysNewTravelerRepository();
      var travelerService = new TravelerService(travelerRepository);

yreynhout

[Test]
public void ConstructorSucceeeds()
{
	var id = new ConcertId(Guid.NewGuid());

	new ConstructorScenario(() => Concert.New(id))
		.Then(ConcertEvents.Planned(id))
		.Assert();
}

yreynhout

                Task flushingTask = null;
                
                public override Task FlushAsync(CancellationToken cancellationToken)
                {
                    Interlocked.CompareExchange(
                        ref flushingTask,
                        Task.Delay(200, cancellationToken).ContinueWith(
                            async (t) =>
                            {
                                await write.FlushAsync(cancellationToken);

yreynhout

1. General Background and Overview

• Probabilistic Data Structures for Web Analytics and Data Mining : A great overview of the space of probabilistic data structures and how they are used in approximation algorithm implementation.
• Models and Issues in Data Stream Systems
• Philippe Flajolet’s contribution to streaming algorithms : A presentation by Jérémie Lumbroso that visits some of the hostorical perspectives and how it all began with Flajolet
• Approximate Frequency Counts over Data Streams by Gurmeet Singh Manku & Rajeev Motwani : One of the early papers on the subject.
• [Methods for Finding Frequent Items in Data Streams](http://citeseerx.ist.psu.edu/viewdoc/download?doi=10.1.1.187.9800&rep

yreynhout

        
        //FromAsync variant that can be used with APM across M<arshaling boundaries (you make your own TArgX overloads, please)
        
        static class MarshalTask 
        {
            public static Task<TResult> FromAsync<TArg1, TArg2, TResult>(Func<TArg1, TArg2, AsyncCallback, object, IAsyncResult> beginFunc, Func<IAsyncResult, TResult> endFunc, TArg1 arg1, TArg2 arg2)
            {
                var cp = new Completer<TResult>(endFunc);
                var tcs = new TaskCompletionSource<TResult>();
                cp.TaskCompletionSource = tcs;

yreynhout

// Use Gists to store code you would like to remember later on
console.log(window); // log the "window" object to the console