Some rxjs 5 lift magic

rxjs5.js

// Before you'd do something like:

var obs = Observable.create((subscriber) => {
  some.other().observable().chain().subscribe({
    next(x){ subscriber.next(x) },
    error(e){ subscriber.error(e) },
    complete(){ subscriber.complete() },
  })
})

// in rxjs 5 you can do

var obs = some.other().observable().chain().lift((subscriber, src) => {
  src.subscribe({
    next(x) { subscriber.next() },
    error(e) { subscriber.error(e) },
    complete() { subscriber.complete() },
  })
})