mirror of
https://github.com/denoland/deno.git
synced 2024-11-24 15:19:26 -05:00
chore(ext/broadcast_channel): custom arity (#14199)
This commit is contained in:
parent
797cf9cdd9
commit
6bb555b549
2 changed files with 3 additions and 3 deletions
|
@ -117,7 +117,7 @@
|
||||||
dispatch(this, this[_name], new Uint8Array(data));
|
dispatch(this, this[_name], new Uint8Array(data));
|
||||||
|
|
||||||
// Send to listeners in other VMs.
|
// Send to listeners in other VMs.
|
||||||
defer(() => core.opAsync("op_broadcast_send", [rid, this[_name]], data));
|
defer(() => core.opAsync("op_broadcast_send", rid, this[_name], data));
|
||||||
}
|
}
|
||||||
|
|
||||||
close() {
|
close() {
|
||||||
|
|
|
@ -68,7 +68,6 @@ where
|
||||||
pub fn op_broadcast_unsubscribe<BC>(
|
pub fn op_broadcast_unsubscribe<BC>(
|
||||||
state: &mut OpState,
|
state: &mut OpState,
|
||||||
rid: ResourceId,
|
rid: ResourceId,
|
||||||
_buf: (),
|
|
||||||
) -> Result<(), AnyError>
|
) -> Result<(), AnyError>
|
||||||
where
|
where
|
||||||
BC: BroadcastChannel + 'static,
|
BC: BroadcastChannel + 'static,
|
||||||
|
@ -81,7 +80,8 @@ where
|
||||||
#[op]
|
#[op]
|
||||||
pub async fn op_broadcast_send<BC>(
|
pub async fn op_broadcast_send<BC>(
|
||||||
state: Rc<RefCell<OpState>>,
|
state: Rc<RefCell<OpState>>,
|
||||||
(rid, name): (ResourceId, String),
|
rid: ResourceId,
|
||||||
|
name: String,
|
||||||
buf: ZeroCopyBuf,
|
buf: ZeroCopyBuf,
|
||||||
) -> Result<(), AnyError>
|
) -> Result<(), AnyError>
|
||||||
where
|
where
|
||||||
|
|
Loading…
Reference in a new issue