Skip to content

Commit 608d598

Browse files
committed
refactor: yjs transport
1 parent dd2f403 commit 608d598

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

app/ydoc-shared/src/util/net/YjsWSTransport.ts renamed to app/ydoc-shared/src/util/net/YjsTransport.ts

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@ export interface AddEventListenerOptions {
2121
signal?: AbortSignal
2222
}
2323

24-
/** Event map for YjsWSTransport events. */
25-
interface YjsWSEventMap {
24+
/** Event map for YjsTransport events. */
25+
interface YjsEventMap {
2626
open: Event
2727
close: CloseEvent
2828
message: MessageEvent<string>
@@ -32,13 +32,13 @@ interface YjsWSEventMap {
3232
type EventListener<T = Event> = (event: T) => void
3333

3434
/** A JSON-RPC transport that uses YjsChannel for communication. */
35-
export class YjsWSTransport extends Transport {
35+
export class YjsTransport extends Transport {
3636
private channel: YjsChannel<string>
3737
private yjsUnsubscribe?: (() => void) | undefined
3838
private eventListeners: Map<string, Set<EventListener<any>>> = new Map()
3939

4040
/**
41-
* Create a {@link YjsWSTransport}.
41+
* Create a {@link YjsTransport}.
4242
* @param doc - The shared Y.Doc document
4343
* @param channelName - The name of the channel (used to get/create the Y.Array)
4444
*/
@@ -94,16 +94,16 @@ export class YjsWSTransport extends Transport {
9494
}
9595

9696
/** Add an event listener. */
97-
on<K extends keyof YjsWSEventMap>(
97+
on<K extends keyof YjsEventMap>(
9898
type: K,
99-
cb: (event: YjsWSEventMap[K]) => void,
99+
cb: (event: YjsEventMap[K]) => void,
100100
options?: AddEventListenerOptions,
101101
): void {
102102
if (!this.eventListeners.has(type)) {
103103
this.eventListeners.set(type, new Set())
104104
}
105105

106-
const wrappedCb = (event: YjsWSEventMap[K]) => {
106+
const wrappedCb = (event: YjsEventMap[K]) => {
107107
cb(event)
108108
if (options?.once) {
109109
this.off(type, cb)
@@ -124,7 +124,7 @@ export class YjsWSTransport extends Transport {
124124
}
125125

126126
/** Remove an event listener. */
127-
off<K extends keyof YjsWSEventMap>(type: K, cb: (event: YjsWSEventMap[K]) => void): void {
127+
off<K extends keyof YjsEventMap>(type: K, cb: (event: YjsEventMap[K]) => void): void {
128128
const listeners = this.eventListeners.get(type)
129129
if (!listeners) return
130130

@@ -138,7 +138,7 @@ export class YjsWSTransport extends Transport {
138138
}
139139

140140
/** Emit an event to all registered listeners. */
141-
private emit<K extends keyof YjsWSEventMap>(type: K, event: YjsWSEventMap[K]): void {
141+
private emit<K extends keyof YjsEventMap>(type: K, event: YjsEventMap[K]): void {
142142
const listeners = this.eventListeners.get(type)
143143
if (!listeners) return
144144

0 commit comments

Comments
 (0)