schemas_test.go

package stream_test

import (
	"fmt"
	"testing"

	"github.com/sokool/stream/example/chat/threads"
)

func TestNewScheme(t *testing.T) {
	//threads, _ := chat.New(NewEngine(t))

	for i := range threads.Events {
		fmt.Println(threads.Events[i])
	}

	//x := threads.(stream.Aggregates[stream.Root])
	//var y stream.Aggregates[stream.Root]

	//fmt.Println(x)
	//s := stream.NewDomain[stream.Aggregates[stream.Root]]()
	//s.Register(threads.(*stream.Aggregates[stream.Root]))

	//fmt.Println(s.Register(threads))
	//o := []stream.Aggregates[stream.Root]{
	//	stream.Aggregates[*model.Thread]{},
	//}
	//fmt.Println(o)
	//s.Register(x.(stream.Aggregates[stream.Root]))
}