Method ProcessPipelineHook

command_recorder_test.go:79–86

(next redis.ProcessPipelineHook)

}

func (h *commandHook) ProcessPipelineHook(next redis.ProcessPipelineHook) redis.ProcessPipelineHook {
	return func(ctx context.Context, cmds []redis.Cmder) error {
		for _, cmd := range cmds {
			h.recorder.Record(cmd.String())
		}
		return next(ctx, cmds)
	}
}