rx-tcn - A Rxjs Observable for Postgresql tcn module

1. Enable tcn module (See: https://www.postgresql.org/docs/current/tcn.html)

2. Install package

npm install rx-tcn pg

3. Usage

import { Pool } from "pg";
import { createTcnSource } from "rx-tcn";

const pool = new Pool();

const obserbale = createTcnSource(pool);

const subscription = obserbale.subscribe({
    next(value) {
        console.log(value); // { tableName: "", operation: "I"|"U"|"D", primaryKey: { ... } }
    },
});

// cleanup
subscription.unsubscribe();