This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | |
}; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// 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())); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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)); | |
}); | |
}; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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(); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
static void Main() | |
{ | |
Recursive(0); | |
} | |
static void Recursive(int i) | |
{ | |
Console.WriteLine(i); | |
Recursive(i + 1); | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
... | |
171424 | |
171425 | |
171426 | |
171427 | |
Process is terminated due to StackOverflowException. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
let rec recursiveFun i = | |
Console.WriteLine(i.ToString()) | |
recursiveFun (i + 1) | |
recursiveFun 0 |
OlderNewer