From 7242f2b5a5118ee5b5cd2295761a703b54cee771 Mon Sep 17 00:00:00 2001
From: Ryan Dahl <ry@tinyclouds.org>
Date: Mon, 11 Jun 2018 21:57:25 +0200
Subject: Add channel to pub/sub

---
 deno2/js/mock_runtime.js | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

(limited to 'deno2/js')

diff --git a/deno2/js/mock_runtime.js b/deno2/js/mock_runtime.js
index 538174f79..081b72c4b 100644
--- a/deno2/js/mock_runtime.js
+++ b/deno2/js/mock_runtime.js
@@ -16,13 +16,15 @@ function CanCallFunction() {
 }
 
 function PubSuccess() {
-  deno_sub(msg => {
+  deno_sub((channel, msg) => {
+    assert(channel === "PubSuccess");
     deno_print("PubSuccess: ok");
   });
 }
 
 function PubByteLength() {
-  deno_sub(msg => {
+  deno_sub((channel, msg) => {
+    assert(channel === "PubByteLength");
     assert(msg instanceof ArrayBuffer);
     assert(msg.byteLength === 3);
   });
@@ -31,16 +33,16 @@ function PubByteLength() {
 function SubReturnEmpty() {
   const ui8 = new Uint8Array("abc".split("").map(c => c.charCodeAt(0)));
   const ab = typedArrayToArrayBuffer(ui8);
-  let r = deno_pub(ab);
+  let r = deno_pub("SubReturnEmpty", ab);
   assert(r == null);
-  r = deno_pub(ab);
+  r = deno_pub("SubReturnEmpty", ab);
   assert(r == null);
 }
 
 function SubReturnBar() {
   const ui8 = new Uint8Array("abc".split("").map(c => c.charCodeAt(0)));
   const ab = typedArrayToArrayBuffer(ui8);
-  const r = deno_pub(ab);
+  const r = deno_pub("SubReturnBar", ab);
   assert(r instanceof ArrayBuffer);
   assert(r.byteLength === 3);
   const rui8 = new Uint8Array(r);
-- 
cgit v1.2.3