Function getMemoryLogStream

getMemoryLogStream(name: string): Observable<RawLogEntry>

Get real-time log stream as an RxJS Observable

Returns only live logs (no replay buffer). Use RxJS operators to filter, throttle, buffer, or otherwise transform the stream.

Parameters

name: string
Registry name of the memory store

Returns Observable<RawLogEntry>

Observable that emits log entries in real-time

Example

// Subscribe to all logs
const logs$ = getMemoryLogStream('api')
logs$.subscribe(log => console.log(log))

Example

// Filter by level using helper operator
import { filterByLevel } from './transports/memory'
logs$.pipe(
  filterByLevel('error')
).subscribe(log => console.error(log))

Example

// Built-in backpressure with throttling
import { withBackpressure } from './transports/memory'
logs$.pipe(
  withBackpressure({ throttleMs: 1000 })
).subscribe(log => sendToSlack(log))