yetangitu/ya-webadb
1
0
Fork 0
mirror of https://github.com/yume-chan/ya-webadb.git synced 2025-10-04 02:09:18 +02:00
Code Issues Projects Releases Packages Wiki Activity

chore: fix eslint errors

Browse source
This commit is contained in:
Simon Chan 2024-07-11 17:35:35 +08:00
parent fb4507ddc5
commit 1d319929ed
No known key found for this signature in database
GPG key ID: A8B69F750B9BCEDD
1 changed files with 16 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

35
libraries/adb/src/commands/subprocess/protocols/shell.spec.ts
View file

@ -1,11 +1,10 @@
import { describe, expect, it } from "@jest/globals";
import { PromiseResolver } from "@yume-chan/async";
import {
ReadableStream,
type ReadableStreamDefaultController,
WritableStream,
} from "@yume-chan/stream-extra";
import { type AdbSocket } from "../../../adb.js";
import type { ReadableStreamDefaultController } from "@yume-chan/stream-extra";
import { ReadableStream, WritableStream } from "@yume-chan/stream-extra";
import type { AdbSocket } from "../../../adb.js";
import {
AdbShellProtocolId,
AdbShellProtocolPacket,
@ -85,7 +84,7 @@ describe("AdbSubprocessShellProtocol", () => {
const stdoutReader = process.stdout.getReader();
const stderrReader = process.stderr.getReader();
stdoutReader.cancel();
await stdoutReader.cancel();
closed.resolve();
await expect(stderrReader.read()).resolves.toEqual({
@ -102,17 +101,15 @@ describe("AdbSubprocessShellProtocol", () => {
describe("`socket` close", () => {
describe("with `exit` message", () => {
it("should close `stdout`, `stderr` and resolve `exit`", async () => {
const [socket, closed] = createMockSocket(
async (controller) => {
controller.enqueue(
AdbShellProtocolPacket.serialize({
id: AdbShellProtocolId.Exit,
data: new Uint8Array([42]),
}),
);
controller.close();
},
);
const [socket, closed] = createMockSocket((controller) => {
controller.enqueue(
AdbShellProtocolPacket.serialize({
id: AdbShellProtocolId.Exit,
data: new Uint8Array([42]),
}),
);
controller.close();
});
const process = new AdbSubprocessShellProtocol(socket);
const stdoutReader = process.stdout.getReader();
@ -175,7 +172,7 @@ describe("AdbSubprocessShellProtocol", () => {
describe("`socket.readable` invalid data", () => {
it("should error `stdout`, `stderr` and reject `exit`", async () => {
const [socket, closed] = createMockSocket(async (controller) => {
const [socket, closed] = createMockSocket((controller) => {
controller.enqueue(new Uint8Array([7, 8, 9]));
controller.close();
});