Ruben Bartelink bartelink

## AwaitWithStopOnCancellation.fs
(*

let a = async {
    let! ct = Async.CancellationToken
    do! System.Threading.Tasks.Task.Delay(5000,ct) |> Async.AwaitTask
}

let b = async {
    failwith "B throw"
}

## AsyncBatchingGate.fs
/// Thread-safe coordinator that batches concurrent requests for a single <c>dispatch</> invocation such that:
/// - requests arriving together can be coalesced into the batch during the linger period via TryAdd
/// - callers that have had items admitted can concurrently await the shared fate of the dispatch via AwaitResult
/// - callers whose TryAdd has been denied can await the completion of the in-flight batch via AwaitCompletion
type internal AsyncBatch<'Req, 'Res>(dispatch : 'Req[] -> Async<'Res>, linger : System.TimeSpan) =
    let lingerMs = int linger.TotalMilliseconds
    // Yes, naive impl in the absence of a cleaner way to have callers sharing the AwaitCompletion coordinate the adding
    do if lingerMs < 5 then invalidArg "linger" "must be >= 5ms"
    let queue = new System.Collections.Concurrent.BlockingCollection<'Req>()
    let dispatch = async {

## keybase id
### Keybase proof

I hereby claim:

  * I am bartelink on github.
  * I am bartelink (https://keybase.io/bartelink) on keybase.
  * I have a public key ASBsuiXja6_19Fq_ZG-VmuGchBYVYRFszqzRoRoy4vDl4go

To claim this, I am signing this object:

## TickSpecXunit2FeatureAttributeAndDiscoverer.fs
namespace TickSpec

open System
open System.Reflection
open System.Threading.Tasks
open Xunit
open Xunit.Abstractions
open Xunit.Sdk

module Impl =

## EventMachines.md

      
              1 file
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                bartelink
                / EventMachines.md
            
            
              Last active
              August 23, 2016 14:47
                — forked from eulerfx/EventMachines.md
            
              
                The relationship between state machines and event sourcing
              
          
    A state machine is defined as follows:

Input - a set of inputs
Output - a set of outputs
State - a set of states
S0 ∈ S - an initial state
T : Input * State -> Output * State - a transition function

If you model your services (aggregates, projections, process managers, sagas, whatever) as state machines, one issue to address is management of State. There must be a mechanism to provide State to the state machine, and to persist the resulting State for subsequent retrieval. One way to address this is by storing State in a key-value store. Another way is to use a SQL database. Yet another way is event sourcing. The benefit of event sourcing is that you never need to store State itself. Instead, you rely on the Output of a service to reconstitute state. In order to do that, the state machine transition function needs to be factored into two functions as follows:

  
## NesGateway.fs
module FunDomain.Persistence.NEventStore.NesGateway

open FunDomain.Persistence.Serialization

open NEventStore
open NEventStore.Persistence
open NEventStore.Persistence.Sql.SqlDialects

open Microsoft.FSharp.Reflection
open System

## AutoControllerData.fs
module WebApi2Helpers

// Port of answer by @nikosbaxevanis :- http://stackoverflow.com/a/19954215/11635

open System
open Ploeh.AutoFixture
open Ploeh.AutoFixture.Kernel
open Ploeh.AutoFixture.Xunit
open Ploeh.AutoFixture.AutoFoq
open System.Web.Http.Hosting

## WarmupCustomization.fs
type TypeThatIsARequestSpecification<'T>() =
    interface IRequestSpecification with
        member this.IsSatisfiedBy request =
            match request with
            | :? System.Type as requestType -> typeof<'T>.IsAssignableFrom( requestType)
            | _ -> false
type PrepareSpecimenCommand<'T>( action) =
    interface ISpecimenCommand with
        member this.Execute( specimen, context) =
            let instance = specimen :?> 'T

## gist:8720521
public static TRes Match<T,TRes>(this FSharpOption<T> opt, Func<T,TRes> some, Func<TRes> none)
{
  if (FSharpOption<T>.get_IsSome(opt))
    return some.Invoke(opt.Value);
  else
    return none.Invoke();
}


## Consolidate-VSFindInFilesSpec.ps1
# TODO dig out of registry instead of cutting and pasting from VS!

$x="*.c;*.cpp;*.cxx;*.cc;*.tli;*.tlh;*.h;*.hh;*.hpp;*.hxx;*.hh;*.inl;*.rc;*.resx;*.idl;*.asm;*.inc;*.tlh;*.h;*.hh;*.hpp;*.hxx;*.hh;*.inl;*.rc;*.resx;*.idl;*.asm;*.inc;*.cs;*.resx;*.resw;*.xsd;*.wsdl;*.xaml;*.xml;*.htm;*.html;*.css;*.vb;*.resx;*.xsd;*.wsdl;*.htm;*.html;*.aspx;*.ascx;*.asmx;*.svc;*.asax;*.config;*.asp;*.asa;*.cshtml;*.vbhtml;*.css;*.xml;*.xml;*.xsl;*.xslt;*.xsd;*.dtd;*.srf;*.htm;*.html;*.xml;*.gif;*.jpg;*.png;*.css;*.disco;*.txt;*.json;*.vb;*.resx;*.xsd;*.wsdl;*.htm;*.html;*.aspx;*.ascx;*.asmx;*.svc;*.asax;*.config;*.asp;*.asa;*.cshtml;*.vbhtml;*.css;*.xml;*.cs;*.resx;*.resw;*.xsd;*.wsdl;*.xaml;*.xml;*.htm;*.html;*.css"

$x+=";*.fs;*.json;*.ts"

# strip *.
$all = $x.Split( ";") | % { $_.Replace("*.","") }

#xml fins too much junk in obj dirs
	(*

	let a = async {
	let! ct = Async.CancellationToken
	do! System.Threading.Tasks.Task.Delay(5000,ct) \|> Async.AwaitTask
	}

	let b = async {
	failwith "B throw"
	}
	/// Thread-safe coordinator that batches concurrent requests for a single <c>dispatch</> invocation such that:
	/// - requests arriving together can be coalesced into the batch during the linger period via TryAdd
	/// - callers that have had items admitted can concurrently await the shared fate of the dispatch via AwaitResult
	/// - callers whose TryAdd has been denied can await the completion of the in-flight batch via AwaitCompletion
	type internal AsyncBatch<'Req, 'Res>(dispatch : 'Req[] -> Async<'Res>, linger : System.TimeSpan) =
	let lingerMs = int linger.TotalMilliseconds
	// Yes, naive impl in the absence of a cleaner way to have callers sharing the AwaitCompletion coordinate the adding
	do if lingerMs < 5 then invalidArg "linger" "must be >= 5ms"
	let queue = new System.Collections.Concurrent.BlockingCollection<'Req>()
	let dispatch = async {
	### Keybase proof

	I hereby claim:

	* I am bartelink on github.
	* I am bartelink (https://keybase.io/bartelink) on keybase.
	* I have a public key ASBsuiXja6_19Fq_ZG-VmuGchBYVYRFszqzRoRoy4vDl4go

	To claim this, I am signing this object:
	namespace TickSpec

	open System
	open System.Reflection
	open System.Threading.Tasks
	open Xunit
	open Xunit.Abstractions
	open Xunit.Sdk

	module Impl =
	module FunDomain.Persistence.NEventStore.NesGateway

	open FunDomain.Persistence.Serialization

	open NEventStore
	open NEventStore.Persistence
	open NEventStore.Persistence.Sql.SqlDialects

	open Microsoft.FSharp.Reflection
	open System
	module WebApi2Helpers

	// Port of answer by @nikosbaxevanis :- http://stackoverflow.com/a/19954215/11635

	open System
	open Ploeh.AutoFixture
	open Ploeh.AutoFixture.Kernel
	open Ploeh.AutoFixture.Xunit
	open Ploeh.AutoFixture.AutoFoq
	open System.Web.Http.Hosting
	type TypeThatIsARequestSpecification<'T>() =
	interface IRequestSpecification with
	member this.IsSatisfiedBy request =
	match request with
	\| :? System.Type as requestType -> typeof<'T>.IsAssignableFrom( requestType)
	\| _ -> false
	type PrepareSpecimenCommand<'T>( action) =
	interface ISpecimenCommand with
	member this.Execute( specimen, context) =
	let instance = specimen :?> 'T
	public static TRes Match<T,TRes>(this FSharpOption<T> opt, Func<T,TRes> some, Func<TRes> none)
	{
	if (FSharpOption<T>.get_IsSome(opt))
	return some.Invoke(opt.Value);
	else
	return none.Invoke();
	}
	# TODO dig out of registry instead of cutting and pasting from VS!

	$x=".c;.cpp;.cxx;.cc;.tli;.tlh;.h;.hh;.hpp;.hxx;.hh;.inl;.rc;.resx;.idl;.asm;.inc;.tlh;.h;.hh;.hpp;.hxx;.hh;.inl;.rc;.resx;.idl;.asm;.inc;.cs;.resx;.resw;.xsd;.wsdl;.xaml;.xml;.htm;.html;.css;.vb;.resx;.xsd;.wsdl;.htm;.html;.aspx;.ascx;.asmx;.svc;.asax;.config;.asp;.asa;.cshtml;.vbhtml;.css;.xml;.xml;.xsl;.xslt;.xsd;.dtd;.srf;.htm;.html;.xml;.gif;.jpg;.png;.css;.disco;.txt;.json;.vb;.resx;.xsd;.wsdl;.htm;.html;.aspx;.ascx;.asmx;.svc;.asax;.config;.asp;.asa;.cshtml;.vbhtml;.css;.xml;.cs;.resx;.resw;.xsd;.wsdl;.xaml;.xml;.htm;.html;*.css"

	$x+=";.fs;.json;*.ts"

	# strip *.
	$all = $x.Split( ";") \| % { $_.Replace("*.","") }

	#xml fins too much junk in obj dirs