MCPcopy
hub / github.com/electric-sql/pglite / #parseNotificationMessage

Method #parseNotificationMessage

packages/pg-protocol/src/parser.ts:281–291  ·  view source on GitHub ↗
(
    offset: number,
    length: number,
    bytes: ArrayBuffer,
  )

Source from the content-addressed store, hash-verified

279 }
280
281 #parseNotificationMessage(
282 offset: number,
283 length: number,
284 bytes: ArrayBuffer,
285 ) {
286 this.#reader.setBuffer(offset, bytes)
287 const processId = this.#reader.int32()
288 const channel = this.#reader.cstring()
289 const payload = this.#reader.cstring()
290 return new NotificationResponseMessage(length, processId, channel, payload)
291 }
292
293 #parseRowDescriptionMessage(
294 offset: number,

Callers 1

#handlePacketMethod · 0.95

Calls 3

setBufferMethod · 0.80
int32Method · 0.80
cstringMethod · 0.80

Tested by

no test coverage detected