-
Notifications
You must be signed in to change notification settings - Fork 0
/
Program.cs
32 lines (28 loc) · 1.14 KB
/
Program.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
using System;
using YasES.Core;
namespace YasES.Examples.Simple
{
class Program
{
static void Main(string[] args)
{
IEventStore eventStore = EventStoreBuilder.Init()
.UseInMemoryPersistance()
.Build();
using (eventStore)
{
const string bucketId = "myBucket";
const string streamId = "myStream";
// add a new event
CommitAttempt commit = new EventCollector()
.Add(new EventMessage("MyEventName", payload: Memory<byte>.Empty))
.BuildCommit(StreamIdentifier.SingleStream(bucketId, streamId));
eventStore.Events.Commit(commit);
// read back the event
ReadPredicate predicate = ReadPredicateBuilder.Forwards(StreamIdentifier.SingleStream(bucketId, streamId));
foreach (var @event in eventStore.Events.Read(predicate))
Console.WriteLine($"Event Name: {@event.EventName}, Created On: {@event.CreationDateUtc:o}, Commited On: {@event.CommitTimeUtc:o}");
}
}
}
}