Function projection

test/integration/features/shared.ts:93–93

(raw: MessageEvent)

  connection.once('close', close.next.bind(close))

  const projection = (raw: MessageEvent) => JSON.parse(raw.data.toString('utf8'))

  const replaySubject = new ReplaySubject(2, 1000)