freeCodeCamp/api-server/common/models/block.js

import { Observable } from 'rx';

export default function(Block) {
  Block.on('dataSourceAttached', () => {
    Block.findOne$ = Observable.fromNodeCallback(Block.findOne, Block);
    Block.findById$ = Observable.fromNodeCallback(Block.findById, Block);
    Block.find$ = Observable.fromNodeCallback(Block.find, Block);
  });
}