Skip to content

Commit

Permalink
forgot the hashtag
Browse files Browse the repository at this point in the history
Signed-off-by: Jersey <[email protected]>
  • Loading branch information
williamhorning committed Mar 23, 2024
1 parent 58aff2a commit c76340d
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/protocol/protocol.ts
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ interface CommandTask {
let nextRequestId = 0;

export class WireProtocol {
conn: Deno.Conn;
#conn: Deno.Conn;
#isPendingResponse = false;
#isPendingRequest = false;
#pendingResponses: Map<number, {
Expand All @@ -29,7 +29,7 @@ export class WireProtocol {
#commandQueue: CommandTask[] = [];

constructor(socket: Deno.Conn) {
this.conn = socket;
this.#conn = socket;
}

async connect() {
Expand Down Expand Up @@ -94,7 +94,7 @@ export class WireProtocol {
],
});

const { write, releaseLock } = this.conn.writable.getWriter();
const { write, releaseLock } = this.#conn.writable.getWriter();
await write(buffer);
releaseLock();
}
Expand Down Expand Up @@ -125,7 +125,7 @@ export class WireProtocol {
private async read_socket(
b: number,
): Promise<Uint8Array | undefined> {
const reader = this.conn.readable.getReader({ mode: "byob" });
const reader = this.#conn.readable.getReader({ mode: "byob" });
const { value } = await reader.read(new Uint8Array(b));
reader.releaseLock();
return value;
Expand Down

0 comments on commit c76340d

Please sign in to comment.