Function initStreamDB

structure/stream_test.go:10–16

()

)

func initStreamDB() (*StreamStructure, *config.Options) {
	opts := config.DefaultOptions
	dir, _ := os.MkdirTemp("", "TestStreamStructure_Get")
	opts.DirPath = dir
	stc, _ := NewStreamStructure(opts)
	return stc, &opts
}

func TestStreamStructure_XRead(t *testing.T) {
	stc, _ := initStreamDB()