Method App.Run has a Cognitive Complexity of 32 (exceeds 20 allowed). Consider refactoring.

Open

func (a *App) Run(ctx context.Context) error {
    col := a.mcli.Collection("tweets")
    for {
        select {
        case <-ctx.Done():

• Read up
  Read up

Method App.Run has 56 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (a *App) Run(ctx context.Context) error {
    col := a.mcli.Collection("tweets")
    for {
        select {
        case <-ctx.Done():

Function NewChangeStream has 5 return statements (exceeds 4 allowed).

Confirmed

func NewChangeStream(ctx context.Context, params ChangeStreamParams, opts ...ChangeStreamOption) (*ChangeStream, error) {
    chopts := &options.ChangeStreamOptions{}
    for _, opt := range opts {
        opt(&ChangeStreamOptions{chopts})
    }