dragonsinth

for it := eventStream.Subscribe().Iterator(); true; {
	v, err := it.Next(ctx)
	if err == eventstream.ErrDone {
		return nil
	} else if err != nil {
		return err
	}
	msg := v.(bwamp.Event)
	// [Send msg to client]
}

dragonsinth

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()

dragonsinth

go install github.com/fullstorydev/go/examples/chatterbox/...@latest
chatterbox server
chatterbox monitor # in another terminal
chatterbox client  # in another terminal

dragonsinth

///usr/bin/env true; exec /usr/bin/env go run "$0" "$@"

package main

import (
	"fmt"
	"log"
	"os"
	"os/exec"
	"path/filepath"

dragonsinth

package concurrency

import (
	"context"
	"fmt"
	"golang.org/x/sync/errgroup"
)

const (
	doThingWorkers    = 4