Function getMemoryStream

apps/sim/lib/table/events.ts:178–190

(tableId: string)

}

function getMemoryStream(tableId: string): MemoryTableStream {
  pruneExpiredMemoryStreams()
  let stream = memoryTableStreams.get(tableId)
  if (!stream) {
    stream = {
      events: [],
      nextEventId: 1,
      expiresAt: Date.now() + TABLE_EVENT_TTL_SECONDS * 1000,
    }
    memoryTableStreams.set(tableId, stream)
  }
  return stream
}

function appendMemory(event: TableEvent): TableEventEntry {
  const stream = getMemoryStream(event.tableId)