ucpr/mongo-streamer

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})
    }