@@ -80,12 +80,12 @@ class EventBufferArray implements IEventBuffer {
8080
8181// exporting for testing
8282export class EventBufferCompressionWorker implements IEventBuffer {
83- private worker : null | Worker ;
84- private eventBufferItemLength : number = 0 ;
83+ private _worker : null | Worker ;
84+ private _eventBufferItemLength : number = 0 ;
8585 private _id : number = 0 ;
8686
8787 constructor ( worker : Worker ) {
88- this . worker = worker ;
88+ this . _worker = worker ;
8989 }
9090
9191 /**
@@ -113,7 +113,7 @@ export class EventBufferCompressionWorker implements IEventBuffer {
113113 }
114114
115115 // At this point, we'll always want to remove listener regardless of result status
116- this . worker ?. removeEventListener ( 'message' , listener ) ;
116+ this . _worker ?. removeEventListener ( 'message' , listener ) ;
117117
118118 if ( ! data . success ) {
119119 // TODO: Do some error handling, not sure what
@@ -136,8 +136,8 @@ export class EventBufferCompressionWorker implements IEventBuffer {
136136
137137 // Note: we can't use `once` option because it's possible it needs to
138138 // listen to multiple messages
139- this . worker ?. addEventListener ( 'message' , listener ) ;
140- this . worker ?. postMessage ( { id, method, args : stringifiedArgs } ) ;
139+ this . _worker ?. addEventListener ( 'message' , listener ) ;
140+ this . _worker ?. postMessage ( { id, method, args : stringifiedArgs } ) ;
141141 } ) ;
142142 }
143143
@@ -148,16 +148,16 @@ export class EventBufferCompressionWorker implements IEventBuffer {
148148
149149 destroy ( ) : void {
150150 __DEBUG_BUILD__ && logger . log ( '[Replay] Destroying compression worker' ) ;
151- this . worker ?. terminate ( ) ;
152- this . worker = null ;
151+ this . _worker ?. terminate ( ) ;
152+ this . _worker = null ;
153153 }
154154
155155 /**
156156 * Note that this may not reflect what is actually in the event buffer. This
157157 * is only a local count of the buffer size since `addEvent` is async.
158158 */
159159 get length ( ) : number {
160- return this . eventBufferItemLength ;
160+ return this . _eventBufferItemLength ;
161161 }
162162
163163 async addEvent ( event : RecordingEvent , isCheckout ?: boolean ) : Promise < string | Uint8Array > {
@@ -182,7 +182,7 @@ export class EventBufferCompressionWorker implements IEventBuffer {
182182 } ) ;
183183
184184 // XXX: See note in `get length()`
185- this . eventBufferItemLength ++ ;
185+ this . _eventBufferItemLength ++ ;
186186
187187 return promise ;
188188 } ;
@@ -191,7 +191,7 @@ export class EventBufferCompressionWorker implements IEventBuffer {
191191 const promise = this . postMessage ( { id, method : 'finish' , args : [ ] } ) ;
192192
193193 // XXX: See note in `get length()`
194- this . eventBufferItemLength = 0 ;
194+ this . _eventBufferItemLength = 0 ;
195195
196196 return promise as Promise < Uint8Array > ;
197197 } ;
0 commit comments