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
# Install boxstarter: | |
# . { iwr -useb http://boxstarter.org/bootstrapper.ps1 } | iex; get-boxstarter -Force | |
# | |
# You might need to set: Set-ExecutionPolicy RemoteSigned | |
# | |
# Run this boxstarter by calling the following from an **elevated** command-prompt: | |
# start http://boxstarter.org/package/nr/url?<URL-TO-RAW-GIST> | |
# OR | |
# Install-BoxstarterPackage -PackageName <URL-TO-RAW-GIST> -DisableReboots | |
# |
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
internal class Supervisor : ReceiveActor, IWithUnboundedStash | |
{ | |
private readonly ILoggingAdapter _log; | |
private readonly IActorRef _messageDispatcher; | |
private readonly IActorRef _messageSink; | |
private readonly IProgressMonitor _progressMonitor; | |
private readonly ISet<IActorRef> _registeredWorkers; | |
private MessagePipelineStatus _status; | |
public Supervisor(IProgressMonitor progressMonitor, IActorRef messageDispatcher, IActorRef messageSink) |
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
public class Supervisor : ReceiveActor, IWithUnboundedStash | |
{ | |
private readonly ISet<IActorRef> _registeredWorkers; | |
private readonly ILoggingAdapter _log; | |
public Supervisor() | |
{ | |
_registeredWorkers = new HashSet<IActorRef>(); | |
_log = Context.GetLogger(); | |
} |
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
public class DonationProjectorTests | |
{ | |
private Func<IEventStorage, InMemoryDonationProjector> _sutFactory; | |
[Test] | |
public void Donation_readmodel_should_be_initialised_correctly() | |
{ | |
new ProjectorScenarioFor<InMemoryDonationProjector, DonationDataModel>(_sutFactory, DonationStreamName.FromString, "d15f54ee8204445a95cff19e826a9746") |
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 AzureBlobStorage | |
open System.IO | |
open Microsoft.WindowsAzure.Storage | |
open Microsoft.WindowsAzure | |
open Microsoft.WindowsAzure.Storage.Blob | |
type Time = | Seconds of int |