1
- import { io } from "./deps.ts" ;
2
- import { assertEquals , assertThrowsAsync , delay , using } from "./deps_test.ts" ;
1
+ import { streams } from "./deps.ts" ;
2
+ import { assertEquals , assertRejects , delay , using } from "./deps_test.ts" ;
3
3
import { Session , SessionClosedError } from "./session.ts" ;
4
4
5
5
class Reader implements Deno . Reader , Deno . Closer {
@@ -67,9 +67,9 @@ Deno.test("Make sure that Reader/Writer for tests works properly", async () => {
67
67
const r = new Reader ( q ) ;
68
68
const w = new Writer ( q ) ;
69
69
const d = ( new TextEncoder ( ) ) . encode ( buildMassiveData ( ) ) ;
70
- await io . writeAll ( w , d ) ;
70
+ await streams . writeAll ( w , d ) ;
71
71
r . close ( ) ;
72
- assertEquals ( await io . readAll ( r ) , d ) ;
72
+ assertEquals ( await streams . readAll ( r ) , d ) ;
73
73
} ) ;
74
74
75
75
Deno . test ( "Local can call Remote method" , async ( ) => {
@@ -219,7 +219,7 @@ Deno.test({
219
219
const writer = new Writer ( buffer ) ;
220
220
const session = new Session ( reader , writer ) ;
221
221
session . close ( ) ;
222
- await assertThrowsAsync ( async ( ) => {
222
+ await assertRejects ( async ( ) => {
223
223
await session . call ( "say" ) ;
224
224
} , SessionClosedError ) ;
225
225
reader . close ( ) ;
@@ -237,7 +237,7 @@ Deno.test({
237
237
const writer = new Writer ( buffer ) ;
238
238
const session = new Session ( reader , writer ) ;
239
239
session . close ( ) ;
240
- await assertThrowsAsync ( async ( ) => {
240
+ await assertRejects ( async ( ) => {
241
241
await session . notify ( "say" ) ;
242
242
} , SessionClosedError ) ;
243
243
reader . close ( ) ;
@@ -268,7 +268,7 @@ Deno.test({
268
268
assertEquals ( await local . call ( "say" ) , "Hello" ) ;
269
269
} ) ;
270
270
// Session is closed by `dispose`
271
- await assertThrowsAsync ( async ( ) => {
271
+ await assertRejects ( async ( ) => {
272
272
await local . call ( "say" ) ;
273
273
} , SessionClosedError ) ;
274
274
// Close
@@ -298,7 +298,7 @@ Deno.test({
298
298
return Promise . reject ( new Error ( "Panic!" ) ) ;
299
299
} ,
300
300
} ) ;
301
- await assertThrowsAsync (
301
+ await assertRejects (
302
302
async ( ) => {
303
303
await local . call ( "say" ) ;
304
304
} ,
@@ -332,7 +332,7 @@ Deno.test({
332
332
return Promise . reject ( "Panic!" ) ;
333
333
} ,
334
334
} ) ;
335
- await assertThrowsAsync (
335
+ await assertRejects (
336
336
async ( ) => {
337
337
await local . call ( "say" ) ;
338
338
} ,
@@ -366,7 +366,7 @@ Deno.test({
366
366
return Promise . reject ( null ) ;
367
367
} ,
368
368
} ) ;
369
- await assertThrowsAsync (
369
+ await assertRejects (
370
370
async ( ) => {
371
371
await local . call ( "say" ) ;
372
372
} ,
0 commit comments