processStreamingResponse.go

stream := resp.GetStream().Reader
events := stream.Events()

var response bedrock.AnthropicResponse

for {
  event := <-events
  if event != nil {
    if v, ok := event.(*types.ResponseStreamMemberChunk); ok {
      // v has fields
      err := json.Unmarshal([]byte(v.Value.Bytes), &response)
      if err != nil {
        log.Printf("unable to decode response:, %v", err)
        continue
      }
      fmt.Printf("%v", response.Completion)
    } else if v, ok := event.(*types.UnknownUnionMember); ok {
      // catchall
      fmt.Print(v.Value)
    }
  } else {
    break
  }
}
stream.Close()