in out_writeapi.go [469:472]
func (r *realManagedWriterClient) NewManagedStream(ctx context.Context, opts ...managedwriter.WriterOption) (*managedwriter.ManagedStream, error) { return r.currClient.NewManagedStream(ctx, opts...) }