11 lines
265 B
JavaScript
11 lines
265 B
JavaScript
|
import { Observable } from 'rx';
|
||
|
|
|
||
|
|
// add rx methods to express
|
||
|
|
export default function expressRx() {
|
||
|
|
return function expressRx(req, res, next) {
|
||
|
|
// render to observable stream
|
||
|
|
res.render$ = Observable.fromNodeCallback(res.render, res);
|
||
|
|
next();
|
||
|
|
};
|
||
|
|
}
|