OnurGumus

module ObservingScheduler


open System
open System.Threading
open Akka.Actor
open Akka.Configuration
open Akka.Event
open Akka.TestKit

OnurGumus

// See https://aka.ms/new-console-template for more information
using Akka.Actor;
using Akka.Streams;
using Akka.Streams.Dsl;

// Create an ActorSystem
using var system = ActorSystem.Create("StreamSystem");

// Create a Materializer
using var materializer = system.Materializer();

OnurGumus

using Marten;
using Marten.Events.Aggregation;
using Marten.Events.Projections;

const string connectionString =
    "PORT = 5432; HOST = localhost; TIMEOUT = 15; POOLING = True; DATABASE = 'marten_cqrs_test'; USER ID = 'test'";

var documentStore = DocumentStore.For(options =>
{
    options.Connection(connectionString);

OnurGumus

open FCQRS.Model.Data
open FCQRS.Model.Aether
open FCQRS.Model.Aether.Operators
open FsToolkit.ErrorHandling
module Domain =

    type FirstName =
        private
        | FirstName of ShortString

OnurGumus

module Aether

open System

// ----------------------------------------------------------------------------
// Optics
// ----------------------------------------------------------------------------

/// Lens from 'a -> 'b.
type Lens<'a,'b> =

OnurGumus

module Aether

open System

//  Optics

/// Lens from 'a -> 'b.
type Lens<'a,'b> =
    ('a -> 'b) * ('b -> 'a -> 'a)

OnurGumus

module Aether

open System

//  Optics

/// Lens from 'a -> 'b.
type Lens<'a,'b> =
    ('a -> 'b) * ('b -> 'a -> 'a)

OnurGumus

// -----------------------------
// 1) Lazy List
// -----------------------------
type 'a lazyList =
    | LNil
    | LCons of Lazy<'a * 'a lazyList>

module LazyList =
    let cons x xs = LCons(lazy (x, xs))
    let empty<'a> : 'a lazyList = LNil

OnurGumus

module Aether

open System

//  Optics

/// Lens from 'a -> 'b.
type Lens<'a,'b> =
    ('a -> 'b) * ('b -> 'a -> 'a)

OnurGumus

type Functor = class end

let inline map (f: 'a -> 'b) (x: ^Functor) : ^Result =
    ((^Functor or ^Result or Functor) : (static member Map : ^Functor * ('a -> 'b) -> ^Result) (x, f))

type Functor with
    static member inline Map (x: list<'a>, f: 'a -> 'b) : list<'b> =
        List.map f x

    static member inline Map (x: option<'a>, f: 'a -> 'b) : option<'b> =