[RFC] midway controller supports returning Observable

[waitingsong]

Midway 的 controller 能否支持直接返回 （rxjs 的） Observable 对象。
nestjs 支持，感觉是比较方便的。

[czy88840616]

粗略想了一下。。没理解。。。有示例么？

[waitingsong]

大致这样：

import { Context, config, controller, get, provide } from 'midway'
import { Observable, timer } from 'rxjs'
import { map } from 'rxjs/operators'


@provide()
@controller('/')
export class HomeController {

  constructor(
    @config() private readonly welcomeMsg: string,
  ) {}

  @get('/', { middleware: ['apiMiddleware'] })
  public index(ctx: Context): Observable<string> {
    return timer(5000).pipe(
      map(() => {
        return `${ this.welcomeMsg } - ${ ctx.api.reqTimeStr }`
      })
    )
  }

}

返回的是 Observable<string> ， 相当于不用在这儿进行 ctx.body 赋值。
好处是 Service 可以返回 Observable 对象，然后可以利用 rxjs 丰富的 operators 操作符在 controller 里面对数据流进行各种合并、变形、转换、延时、防抖等等处理后直接丢出流。
这个需求可能受众不大。

[czy88840616]

这个貌似没见过。。。虽然看过nest有这样搞。。不过他是配合他的整个流程，加上拦截器，包了 express，而koa 这边因为本身自带了洋葱模型，所以再写一个就很奇怪。可能 Observable 可以作为核心能力的一部分，甚至单独出一个 Midway-Observable 来尝试写法都可以。

[waitingsong]

是的，这个改动会比较大。
如果仅仅是判断 controller 返回的是 Observable 然后 obv.toPromise() 就可解决。不过意义不大，要发挥 rxjs 的优势得全生命周期支持。

[czy88840616]

所以可能得来个 midway for rxjs ?

[waitingsong]

估计 midway grpc 优先级还高些。

[czy88840616]

😄 GRPC。。在做faas的时候用到了，发现和java交互有点问题。。

[waitingsong]

和 golang 交互没问题吧。那锅就是 java 的了嘛……

[czy88840616]

没错，就是java的锅。