MiloszKrajewski

internal static class TypeExtensions
{
    /// <summary>
    /// Type distance cache. It should Concurrent dictionary but it is not available
    /// on all flavors of Portable Class Library.
    /// </summary>
    private static readonly ConcurrentDictionary<(Type, Type), int> TypeDistanceMap = new();

    /// <summary>Checks if child type inherits (or implements) from parent.</summary>
    /// <param name="child">The child.</param>

MiloszKrajewski

public class Pool<T>
{
	private readonly ConcurrentQueue<T> _queue;
	private readonly Func<T> _create;
	private readonly Action<T> _reset;
	private readonly Action<T> _destroy;
	private int _freeSlots;

	public Pool(Func<T> create, Action<T> reset, Action<T> destroy, int size)
	{

MiloszKrajewski

<ItemGroup>
  <Content Include="../OtherLib/Internal/**/*.*">
    <Link>Shared/Internal/%(RecursiveDir)%(Filename)%(Extension)</Link>
  </Content>
</ItemGroup>

MiloszKrajewski

$root = $PSScriptRoot
$version = "12.0-1"
$pg_bin = "$root/bin/pgsql/bin"
$pg_exe = "$pg_bin/postgres.exe"

function Decrypt-SecureString([SecureString] $secure) {
    return [System.Runtime.InteropServices.marshal]::PtrToStringAuto([System.Runtime.InteropServices.marshal]::SecureStringToBSTR($secure))
}

function UnzipUrl([string] $url, [string] $outpath) {

MiloszKrajewski

/// <summary>
/// Helper class replacing Dapper.
/// </summary>
internal static class Dapperito
{
	public static DbCommand CreateCommand(this DbConnection connection, string sql)
	{
		var command = connection.CreateCommand();
		command.CommandText = sql;
		return command;

MiloszKrajewski

open System

let rec between a z = 
    if a = z then a
    elif a > z then between z a
    else
        let rec between a z acc =
            match a, z with
            | [], z -> between ['a'] z acc
            | a, [] -> between a ['z'] acc

MiloszKrajewski

open System.Diagnostics

let root = __SOURCE_DIRECTORY__
let debug = false

let exec directory executable arguments =
    let info = 
        ProcessStartInfo(
            executable, arguments,
            UseShellExecute = false, CreateNoWindow = not debug, WorkingDirectory = directory)

MiloszKrajewski

define actor:

• var props = Props.FromProducer(() => actor);
• var props = Props.FromFunc(context => { ... });

configure actor:

• props.WithDispatcher(dispatcher);
• props.WithMailbox(() => mailbox);
• props.WithSupervisor(strategy);
• props.WithSenderMiddleware(middleware[]);
• props.WithReceiveMiddleware(middleware[]);

MiloszKrajewski

/*
Microsoft.Extensions.DependencyInjection
Microsoft.Extensions.Logging
Microsoft.Extensions.Configuration
*/

using System;
using System.IO;
using System.Reflection;
using System.Threading.Tasks;

MiloszKrajewski

private static async Task<HttpRequestMessage> CloneRequest(HttpRequestMessage request)
{
    var clone = new HttpRequestMessage(request.Method, request.RequestUri);

    if (request.Content != null)
    {
        var stream = await request.Content.ReadAsStreamAsync();
        if ((stream.Length > 0 || request.Content.Headers.Any())
            && clone.Method != HttpMethod.Get)
        {