Go - Collection.Query.Stream()

import (
  "context"
  "fmt"

  "github.com/nitrictech/go-sdk/nitric"
)

func main() {
  profiles, err := nitric.NewCollection("profiles").With(nitric.CollectionReading)
  if err != nil {
    return
  }

  stream, err := profiles.Query().Stream(context.TODO())
  if err != nil {
    return
  }

  nitric.Run()
}

import (
  "context"
  "fmt"

  "github.com/nitrictech/go-sdk/nitric"
)

func main() {
  profiles, err := nitric.NewCollection("profiles").With(nitric.CollectionReading)
  if err != nil {
    return
  }

  stream, err := profiles.Query().Stream(context.TODO())
  if err != nil {
    return
  }

  for {
    res, err := stream.Next()
    if err != nil {
      fmt.Println("finished processing with: %w", err)
      break
    }

    fmt.Println(res.Content())
  }

  nitric.Run()
}