I hereby claim:
- I am jasonmitchell on github.
- I am jasonmitchell (https://keybase.io/jasonmitchell) on keybase.
- I have a public key whose fingerprint is BD48 5BB9 3F4D 1463 BE4E CE8E C9BC 9458 59A1 B9DC
To claim this, I am signing this object:
| using System; | |
| using Autofac; | |
| using FluentValidation; | |
| namespace Sample.Web.Infrastructure | |
| { | |
| public class AutofacValidatorFactory : ValidatorFactoryBase | |
| { | |
| private readonly IComponentContext _context; |
| namespace Sample.Repositories.Specifications | |
| { | |
| using System; | |
| using System.Linq; | |
| using System.Linq.Expressions; | |
| internal class AndSpecification<T> : ISpecification<T> | |
| { | |
| private readonly ISpecification<T> left; | |
| private readonly ISpecification<T> right; |
| $username = "$my-website" | |
| $password = "password" | |
| $base64AuthInfo = [Convert]::ToBase64String([Text.Encoding]::ASCII.GetBytes(("{0}:{1}" -f $username, $password))) | |
| $apiUrl = "https://my-website.scm.azurewebsites.net/api/command" | |
| $commandBody = @{ | |
| command = "del /S /F /Q .\\" | |
| dir = "site\\wwwroot" | |
| } |
| fromCategory('MyOldStreamCategory') | |
| .whenAny(function (s, e) { | |
| var newStreamName = e.streamId.replace('MyOldStreamCategory', 'MyNewStreamCategory'); | |
| emit(newStreamName, e.eventType, e.data, e.metadata); | |
| }) |
I hereby claim:
To claim this, I am signing this object:
| class Order : Aggregate | |
| { | |
| static Order() | |
| { | |
| Given<Order, OrderStarted>((x, e) => | |
| { | |
| x.Id = e.Id; | |
| x.customerId = e.CustomerId; | |
| x.status = OrderStatus.Open; | |
| x.tickets = new List<Ticket>(); |
| [Fact] | |
| public async Task ReadsEventsFromStream() | |
| { | |
| // Create a connection to the embedded event store. | |
| using (var connection = EmbeddedEventStoreConnection.Create(_node, _connectionSettingsBuilder)) | |
| { | |
| // Write some events - omitted for clarity | |
| // When reading from a stream you can specify the start position and how many events to read. | |
| // The maximum number of events that can be read in one call is 4096 to large streams would require reading in pages. |
| using System; | |
| using System.Collections.Generic; | |
| namespace Aggregates | |
| { | |
| public abstract class Aggregate : IAggregate | |
| { | |
| private readonly Dictionary<Type, Action<object>> handlers = new Dictionary<Type, Action<object>>(); | |
| private readonly Queue<object> uncommittedEvents = new Queue<object>(); | |
| private int version; |
| MemDb: true | |
| Log: .\2113-logs | |
| IntIp: 127.0.0.1 | |
| ExtIp: 127.0.0.1 | |
| IntTcpPort: 1112 | |
| ExtTcpPort: 1113 | |
| IntHttpPort: 2112 | |
| ExtHttpPort: 2113 | |
| IntHttpPrefixes: http://*:2112/ | |
| ExtHttpPrefixes: http://*:2113/ |
| Single node | |
| Any HTTPS request from external source. | |
| Some extra logging added | |
| Still exists on mono 5.0.0 | |
| Curl to https://127.0.0.1:2113/ping | |
| Response received | |
| "SslStream already authenticated" logged | |
| Navigate to https://127.0.0.1:2113 in a browser |