Function pruneExpiredMemoryStreams

apps/sim/lib/table/events.ts:170–176

(now = Date.now())

}

function pruneExpiredMemoryStreams(now = Date.now()): void {
  for (const [tableId, stream] of memoryTableStreams) {
    if (stream.expiresAt <= now) {
      memoryTableStreams.delete(tableId)
    }
  }
}

function getMemoryStream(tableId: string): MemoryTableStream {
  pruneExpiredMemoryStreams()