eventstream_model.go

type LogReplicatedModel struct {
	mu       sync.RWMutex
	snapshot Model
	stream   eventstream.EventStream
}

func (m *LogReplicatedModel) ReadAndSubscribe() (Model, eventstream.Promise) {
	m.mu.RLock()
	defer m.mu.RUnlock()
	return m.snapshot, m.stream.Subscribe()
}

func (m *LogReplicatedModel) WriteAndPublish(mutation Mutation) {
	m.mu.Lock()
	defer m.mu.Unlock()
	m.snapshot = m.snapshot.ApplyMutation(mutation)
	m.stream.Publish(mutation)
}