diff options
| author | Bert Belder <bertbelder@gmail.com> | 2021-01-14 20:32:27 -0800 |
|---|---|---|
| committer | Bert Belder <bertbelder@gmail.com> | 2021-01-29 01:35:07 -0800 |
| commit | 98878bd81231a631c494b6767576097f945eb813 (patch) | |
| tree | f66f027cf9692548696a7ce5417fba60cec51f60 /runtime/ops/net_unix.rs | |
| parent | c8a5e3c1e485915880bd5ed10438ac87baf4a80b (diff) | |
refactor: IO resource types, fix concurrent read/write and graceful close (#9118)
Fixes: 9032.
Diffstat (limited to 'runtime/ops/net_unix.rs')
| -rw-r--r-- | runtime/ops/net_unix.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/runtime/ops/net_unix.rs b/runtime/ops/net_unix.rs index 1177d071c..c3e561568 100644 --- a/runtime/ops/net_unix.rs +++ b/runtime/ops/net_unix.rs @@ -1,6 +1,6 @@ // Copyright 2018-2021 the Deno authors. All rights reserved. MIT license. -use crate::ops::io::StreamResource; +use crate::ops::io::UnixStreamResource; use crate::ops::net::AcceptArgs; use crate::ops::net::ReceiveArgs; use deno_core::error::bad_resource; @@ -81,7 +81,7 @@ pub(crate) async fn accept_unix( let local_addr = unix_stream.local_addr()?; let remote_addr = unix_stream.peer_addr()?; - let resource = StreamResource::unix_stream(unix_stream); + let resource = UnixStreamResource::new(unix_stream.into_split()); let mut state = state.borrow_mut(); let rid = state.resource_table.add(resource); Ok(json!({ |