JefClaes

var Config = require('../config.js').Config;
var eventstore = require('eventstore');
var storage = require('eventstore.mongodb');

var es;

var S4 = function() {
    return Math.floor((1 + Math.random()) * 0x10000).toString(16).substring(1);
};

JefClaes

// Udi style w Static Domain Events

var dispatcher = new RecordingDomainEventsDispatcher();

DomainEvents.Dispatcher = dispatcher;

var customer = new Customer(new Address());
customer.Move(new Address());

Console.WriteLine("Customer moved: " + dispatcher.RecordedDomainEvent(new CustomerMoved()));

JefClaes

var ajaxWidgetModel = function (options) {
    var self = this;

    self.data = ko.observable();
    self.tick = function () {
        $.get(options.url, function (data) {
            self.data(ko.mapping.fromJS(data));
        });
    };

JefClaes

var ticks = Observable.Interval(TimeSpan.FromSeconds(_settings.IntervalInSeconds));

var pollResults = Observable.Create<PollResult>(observer =>
{
    var results = // do request
    
    foreach (var result in results) 
      observer.OnNext(new PollResult(result));
    
    return Disposable.Empty;

JefClaes

class Program
{
  static void Main(string[] args)
  {
      var item = InventoryItemPure.Register(new InventoryItemName("Domain Driven Design"));
      item = InventoryItemPure.CheckIn(item, new InventoryItemCount(4));
      item = InventoryItemPure.CheckOut(item, new InventoryItemCount(3));
      item = InventoryItemPure.Deactivate(item);

      Console.ReadLine();

JefClaes

module Program
open Inventory
open System

[<EntryPoint>]
let main argv =
    let item = Inventory.Register (Inventory.InventoryItemName.Make "Domain Driven Design") 
    let itemAfterCheckingIn = Inventory.CheckIn (InventoryItemCount.Make 3) item
    let itemAfterCheckingOut = Inventory.CheckOut (InventoryItemCount.Make 1) itemAfterCheckingIn
    let deactivatedItem = Inventory.Deactivate itemAfterCheckingOut

JefClaes

let rec read stream startFrom (conn : IEventStoreConnection) = 
    seq {
        let size = 10000
        let slice = conn.ReadStreamEventsForwardAsync(stream, startFrom, size, true).Result

        if (slice.IsEndOfStream) then
           yield slice
        else
           yield slice
           yield! read stream (startFrom + size) conn 

JefClaes

static void Main()
{
    Recursive(0);
}

static void Recursive(int i)
{
    Console.WriteLine(i);
    Recursive(i + 1);
}

JefClaes

...
171424
171425
171426
171427
Process is terminated due to StackOverflowException.

JefClaes

let rec recursiveFun i =
    Console.WriteLine(i.ToString()) 
    recursiveFun (i + 1)
 
recursiveFun 0