geyser-mongo

Geyser

Publish and subscribe to streams of data over MongoDB.

Usage

Source Node.js process:

import { Observable } from 'rxjs';
import { MongoObserver } from 'geyser-mongo';
 
// Create an Observer which writes to a 'ticks' collection in MongoDB
const ticks = MongoObserver.connect({
  url: 'mongodb://localhost/my-db',
  collection: 'ticks'
})
 
// Subscribe our "ticks" observer to a stream
Observable.interval(1000).subscribe(ticks);

Listening Node.js process:

import { MongoObservable } from 'geyser-mongo';
 
// create a 
const ticks = MongoObservable.connect({
  url: 'mongodb://localhost/my-db',
  collection: 'ticks'
})
 
// Subscribe to the "ticks" stream
ticks.subscribe(console.log);
 
// 1
// 2
// 3
// ...