)

func newStringRSC(s string) io.ReadSeekCloser {
	return newBytesRSC([]byte(s))
}

func newBytesRSC(b []byte) io.ReadSeekCloser {
	r := bytes.NewReader(b)
	segmentReader := func(offset int64) (io.ReadCloser, error) {
		_, err := r.Seek(offset, io.SeekStart)
		if err != nil {
			return nil, err
		}
		return io.NopCloser(r), nil
	}
	return NewObjectReadSeekCloser(segmentReader, int64(len(b)))
}

     *
     * @return The list of search result documents
     */
    public List<Map<String, Object>> getDocumentList() {
        return documentList;
    }

    /**
     * Gets the total number of records that match the search criteria.
     *
     * @return The total record count
     */
    public long getAllRecordCount() {
        return allRecordCount;
    }

    /**

		return nil
	}
	if *s.Start > *s.End {
		return errors.New("ScanRange: Start cannot be after end")
	}
	return nil
}

// StartLen returns start offset plus length from range.
func (s *ScanRange) StartLen() (start, length int64, err error) {
	if s == nil {
		return 0, -1, nil
	}
	err = s.Validate()
	if err != nil {
		return 0, 0, err
	}

	if s.End == nil && s.Start == nil {

        }
        return t;
    }

    @SuppressWarnings("unchecked")
    @Override
    public <T extends Credentials> T unwrap(Class<T> t) {
        if (t.isAssignableFrom(this.getClass())) {
            return (T) this;
        }
        return null;
    }

    @Override
    public Subject getSubject() {
        return null;
    }

    @Override

        }

        CacheRecord record = new CacheRecord(projectRealm, extensionArtifactFilter);

        cache.put(key, record);

        return record;
    }

    @Override
    public void flush() {
        for (CacheRecord record : cache.values()) {
            ClassRealm realm = record.getRealm();
            try {

// Reader - JSON record reader for S3Select.
type Reader struct {
	args       *ReaderArgs
	decoder    *jstream.Decoder
	valueCh    chan *jstream.MetaValue
	readCloser io.ReadCloser
}

// Read - reads single record.
func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
	v, ok := <-r.valueCh
	if !ok {
		if err := r.decoder.Err(); err != nil {
			return nil, errJSONParsingError(err)
		}

     * Checks the configured secure setting or examines request headers to detect HTTPS.
     *
     * @return true if the cookie should be secure, false otherwise
     */
    protected boolean isSecureCookie() {
        if (cookieSecure != null) {
            return cookieSecure;
        }

        return LaRequestUtil.getOptionalRequest().map(req -> {

     * Returns the default current page number for pagination.
     *
     * @return the default current page number (typically 1)
     */
    protected int getDefaultCurrentPageNumber() {
        return DEFAULT_CURRENT_PAGE_NUMBER;
    }

    /**
     * Gets the total number of records available across all pages.
     *
     * @return the total record count
     */
    public int getAllRecordCount() {

	return c.db.Ping()
}

// If you use BeginTx returned *sql.Tx as shown below then you can't record queries in a transaction.
//
//	func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) {
//		 return c.db.BeginTx(ctx, opts)
//	}
//
// You should use BeginTx returned gorm.Tx which could wrap *sql.Tx then you can record all queries.

        return this;
    }

    public PomBuilder artifactId(String artifactId) {
        this.artifactId = artifactId;
        return this;
    }

    public PomBuilder version(String version) {
        this.version = version;
        return this;
    }

    public PomBuilder packaging(String packaging) {
        this.packaging = packaging;
        return this;
    }