janderit

public sealed class DatabaseObserver : IDisposable
    {
        private readonly string _connectionstring;
        private readonly string _sqlcommand;
        private readonly Action<Observation> _onChange;
        private readonly Action<Exception> _onError;
        private readonly Action<string> _onWarning;
        private SqlConnection _connection;
        private SqlCommand _cmd;
        private SqlDependency _dependency;

janderit

    /// <summary>
    /// Encapsulates a zeroMQ context and a worker thread.
    /// Use the ZmqPollPool to server multiple 0mq sockets with single-threaded semantics.
    /// 
    /// Use MarshalAndWait or MarshalAsync to marshal 0mq context access to the working thread.
    /// Call Dispose to close all registered sockets and terminate the context and thread.
    /// </summary>
    public class ZmqPollPool : IDisposable
    {
        private TimeSpan _pollTimeout;

janderit

//
// Functional Bowling Kata solution in F#
//
// uses recursive determination of the score starting with a certain frame number
// and lookahead for the bonus roll scores
//

let private frames_in_game = 10

type FrameType = Strike | Spare | Normal

janderit

// Event-sourced solution to the Bowling Kata
// This is obviously neither a 'simple' solution for the Kata, nor an infrastructure focussed event sourcing demo,
// but rather intended to demonstrate event sourcing *principles* in a minimalistic domain.
// Philip Jander, 2019
// (thanks to Ralf Westphal (@ralfw) for posing the challenge)

// ATTN: functional code, read from the end of the file :)

/// Computation Expression Builder for functional event sourcing
module EventSourced = 

janderit

using System;
using System.Collections.Generic;

namespace Sandbox
{
    class Program
    {
        public Program()
        {
            Readonly_mit_Field = 5;

janderit

##########################################################################
# RAKE BUILD SCRIPT                                                      #
# (c) Philip Jander 2012, 2013                                           #
# Jander.IT                                                              #
##########################################################################

RAKEFILE_REVISION = "2.3"

#
# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED 

janderit

public sealed class Host
    {
        private readonly string _zmqEndpoint;
        private readonly Action<Action> _dispatcher;
        private static ZmqSocket _server;
        private static readonly ConcurrentQueue<Action> WaitToSend = new ConcurrentQueue<Action>();

        public Host(string zmqEndpoint, Action<Action> dispatcher)
        {
            _zmqEndpoint = zmqEndpoint;

janderit

    public static class CollectionExtender
    {
        public static IEnumerable<string> NonBlank(this IEnumerable<string> list)
        {
            return list.Where(_ => !String.IsNullOrWhiteSpace(_));
        }

        public static IEnumerable<T> NonNull<T>(this IEnumerable<T> list) where T:class
        {
            return list.Where(_ => null != (object) _);

janderit

(*
The goal in this exercise is to create a model to predict
how many bicycles will be used in a day, given the
available information.

Data source: UC Irvine Machine Learning dataset, "bike sharing":
https://archive.ics.uci.edu/ml/datasets/Bike+Sharing+Dataset

We will first explore the data, using the CSV type provider
and fsharp.Charting to visualize it.

janderit

// adapted from : http://stackoverflow.com/questions/3151702/discriminated-union-in-c-sharp by Juliet
    public abstract class Union<TA, TB, TC>
    {
        public static Case1 Create(TA x) { return new Case1(x);}
        public static Case2 Create(TB x) { return new Case2(x);}
        public static Case3 Create(TC x) { return new Case3(x);}

        public abstract T Match<T>(Func<TA, T> f, Func<TB, T> g, Func<TC, T> h);
        private Union() { }