afifmohammed

namespace Sagas
{
    using System;
    using System.Collections.Generic;
    

    class Program
    {
        static ActivityHost[] processes;

afifmohammed

    public class ConcurrentGateway
    {
        private ConcurrentQueue<Action> _workQueue = new ConcurrentQueue<Action>();
        private int _writeLock = 0;

        private static AutoResetEvent _waitEvent = new AutoResetEvent(false);

        protected static AutoResetEvent GetThreadWaitEvent()
        {
            //returns same event for all threads ,but we could easily provide a

afifmohammed

using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Collections.Concurrent;
using System.Reflection.Emit;
using System.Threading;

afifmohammed

CREATE DATABASE [OrderedInsert]
GO

ALTER DATABASE [OrderedInsert] SET ALLOW_SNAPSHOT_ISOLATION ON 
GO

USE [OrderedInsert]
GO

CREATE TABLE [dbo].[Test](

afifmohammed

$ErrorActionPreference = "Stop"

function cleanBin {
   param ([string]$path) 
 
    write-host "Cleaning bin from: $path"
    get-childitem $path -include bin -recurse | remove-item -force -confirm:$false -recurse

    write-host "Cleaning obj from: $path"
    get-childitem $path -include obj -recurse | remove-item -force -confirm:$false -recurse

afifmohammed

using System;

namespace PureIO {
  /*
    C# does not have proper sum types. They must be emulated.

    This data type is one of 4 possible values:
    - WriteOut, being a pair of a string and A
    - WriteErr, being a pair of a string and A
    - readLine, being a function from string to A

afifmohammed

using System;

namespace Funcs {
  public static class Funcs {
    public static Func<A, C> Select<A, B, C>(this Func<A, B> f, Func<B, C> g) {
      return a => g(f(a));
    }

    public static Func<C, B> SelectMany<A, B, C>(this Func<C, A> f, Func<A, Func<C, B>> g) {
      return a => g(f(a))(a);

afifmohammed

public static class ReaderMonadExt
{
	public static Func<T, C> SelectMany<T, A, B, C>(this Func<T, A> t_a, Func<A, Func<T, B>> a_t_b, Func<A, B, C> ab_c)
	{
		return t =>
		{
			var a = t_a(t);
			return ab_c(a, a_t_b(a)(t));
		};
	}

afifmohammed

using System;
using System.Threading.Tasks;

namespace GenericMonad
{
	public class Async
	{
		Async ()
		{

afifmohammed

//
// See https://github.com/louthy/language-ext
// 

using System;
using System.IO;
using System.Linq;
using System.Threading.Tasks;
using LanguageExt;
using static LanguageExt.Prelude;