Function createTestSocket

src/utils/__tests__/ndjsonFramer.test.ts:11–23

()

}

function createTestSocket(): TestSocket {
  const emitter = new EventEmitter() as TestSocket
  emitter.destroyed = false
  emitter.destroy = ((_error?: Error) => {
    emitter.destroyed = true
    emitter.emit('close')
    return emitter
  }) as TestSocket['destroy']
  emitter.emitData = (chunk: Buffer) => {
    emitter.emit('data', chunk)
  }
  return emitter
}

describe('attachNdjsonFramer', () => {
  test('accepts a complete frame at the configured byte limit', () => {