func (d *db) Changes(ctx context.Context, opts map[string]interface{}) (driver.Changes, error) {
	overrideOpts := map[string]interface{}{
		"feed":      "continuous",
		"since":     "now",
		"heartbeat": 6000,
	}
	options, err := optionsToParams(opts, overrideOpts)
	if err != nil {
		return nil, err
	}
	resp, err := d.Client.DoReq(ctx, kivik.MethodGet, d.path("_changes", options), nil)
	if err != nil {
		return nil, err
	}
	if err = chttp.ResponseError(resp); err != nil {
		return nil, err
	}
	return newChangesRows(resp.Body), nil
}
// Changes returns the changes stream for the database.
Changes returns the changes stream for the database.
// Changes returns the changes stream for the database .
func (d *db) Changes(ctx context.Context, opts map[string]interface{}) (driver.Changes, error) {
	overrideOpts := map[string]interface{}{
		"feed":      "continuous",
		"since":     "now",
		"heartbeat": 6000,
	}
	options, err := optionsToParams(opts, overrideOpts)
	if err != nil {
		return nil, err
	}
	resp, err := d.Client.DoReq(ctx, kivik.MethodGet, d.path("_changes", options), nil)
	if err != nil {
		return nil, err
	}
	if err = chttp.ResponseError(resp); err != nil {
		return nil, err
	}
	return newChangesRows(resp.Body), nil
}
func ( d * db ) Changes ( ctx context . Context , opts map [ string ] interface { } ) ( driver . Changes , error ) { overrideOpts := map [ string ] interface { } { " " : " " , " " : " " , " " : 6000 , } options , err := optionsToParams ( opts , overrideOpts ) if err != nil { return nil , err } resp , err := d . Client . DoReq ( ctx , kivik . MethodGet , d . path ( " " , options ) , nil ) if err != nil { return nil , err } if err = chttp . ResponseError ( resp ) ; err != nil { return nil , err } return newChangesRows ( resp . Body ) , nil }
Changes returns the changes stream for the database.
Changes returns the changes stream for the database .