Subscribe, unsubscribe, resubscribe about redis HOT 4 CLOSED

import { connect } from "./redis.ts";
import { assertEquals } from "./vendor/https/deno.land/std/assert/mod.ts";

const opts = {
  hostname: "127.0.0.1",
  port: 6379
};
const redis = await connect(opts);
const pub = await connect(opts);
const channel = "foobar";
const sub = await redis.subscribe(channel);
const messages = [];
try {
  const promise = (async () => {
    for await (const m of sub.receive()) {
      messages.push(m);
      break;
    }
  })();
  await pub.publish(channel, "message");

  await promise;
  await sub.unsubscribe(channel);
  await sub.subscribe(channel);

  const promise2 = (async () => {
    for await (const m of sub.receive()) {
      messages.push(m);
      break;
    }
  })();
  await pub.publish(channel, "message 2");

  await promise2;
} finally {
  sub.close();
  redis.close();
  pub.close();
}
assertEquals(messages, [
  { channel, message: "message" },
  { channel, message: "message 2" }
]);