1 | const asyncRedis = require("../src");
|
2 | const client = asyncRedis.createClient();
|
3 |
|
4 | client.on("error", function (err) {
|
5 | console.log("Error " + err);
|
6 | });
|
7 |
|
8 | let addToSet = async () => {
|
9 | let key = 'exampleSet';
|
10 | let values = [
|
11 | 'item_1',
|
12 | 'item_2',
|
13 | 'item_3',
|
14 | 'item_4',
|
15 | 'item_5',
|
16 | ];
|
17 | let promises = values.map((value) => {
|
18 | return client.sadd(key, value);
|
19 | });
|
20 | await Promise.all(promises);
|
21 | return await client.smembers(key);
|
22 | };
|
23 |
|
24 | let flush = async () => {
|
25 | return await client.flushall();
|
26 | };
|
27 |
|
28 | addToSet()
|
29 | .then((results) => {
|
30 | console.log(results);
|
31 | return flush();
|
32 | })
|
33 | .then((results) => {
|
34 | console.log(results);
|
35 | process.exit();
|
36 | })
|
37 | .catch((error) => {
|
38 | console.log(error);
|
39 | process.exit();
|
40 | });
|