class Movie::Persistence::ProjectionRunner

Overview

Bounded, restartable projection step. The checkpoint advances only after the handler returns, so a crash can redeliver but cannot skip an event.

Defined in:

movie/persistence/runtime.cr

Constructors

.new(database : Movie::DatabaseExtension, name : String, page_size : Int32 = 100, persistence_id : String | Nil = nil)

Instance Method Summary

#run_once(&handler : EventEnvelope -> ) : ProjectionRunResult

Constructor Detail

def self.new(database : Movie::DatabaseExtension, name : String, page_size : Int32 = 100, persistence_id : String | Nil = nil) #

[View source]

Instance Method Detail

def run_once(&handler : EventEnvelope -> ) : ProjectionRunResult #

[View source]