crypto-brain.ts

const observables: any = {}
const subjects: any = {}

observables.log = Observable.create(subject => {
    subjects.log = subject
})

function log(...msgs) {
    console.log(...msgs)

    if (subjects.log) {
        subjects.log.next(msgs)
    }
}

export async function init() {
    return {
        name: 'crypto',
        observables,
    }
}

index.ts

export async function init() {
    for (const brain of brains) {
        const res = await brain.init()

        if (res && res.observables && res.observables.log) {
            res.observables.log.subscribe(function(msgs) {
                db.logs.insert({ brain: res.name, messages: msgs })
            })
        }
    }
}