RxJS 与 Angular4：使用 Next.js 自动加载数据

随着 Web 应用程序的复杂度不断增加，客户端应用程序的数据流管理变得越来越重要。 RxJS 是一个在 Angular4 中广泛使用的库，它提供了一组强大的工具和抽象，使得处理异步数据变得更加简单和直观。 在本文中，我们将探讨如何使用 RxJS 和 Angular4 创建自动加载数据的 Next.js 应用程序。

环境和依赖项

我们将使用 Angular4 和 RxJS 5 来创建我们的 Next.js 应用程序。请确保你已经安装了这两个 Node.js 模块：

npm install --save @angular/core rxjs

我们还需要安装 next 和 @zeit/next-rxjs 包：

npm install --save next @zeit/next-rxjs

创建应用程序

使用 create-next-app 工具创建一个新的 Next.js 应用程序，我们需要在根目录下创建一个名为 pages 的目录：

mkdir pages

现在它的初始结构应该是这样的：

.
├── node_modules
├── pages
├── package.json
└── yarn.lock

我们需要创建一个新的文件 pages/index.js ，并将下面的内容复制到该文件中：

// javascriptcn.com 代码示例
import { Observable } from 'rxjs/Observable'
import { Component } from '@angular/core'
import { fromPromise } from 'rxjs/observable/fromPromise'
import { map } from 'rxjs/operators/map'
import { startWith } from 'rxjs/operators/startWith'
import { withLatestFrom } from 'rxjs/operators/withLatestFrom'
import { combineLatest } from 'rxjs/observable/combineLatest'
import { of } from 'rxjs/observable/of'
import { Subject } from 'rxjs/Subject'

import { createWrapper } from '@zeit/next-rxjs'

const search$ = new Subject()

@Component({
  selector: 'app-root',
  template: `
    <form>
      <input type="text" placeholder="Search Github Users" (input)="search$.next($event.target.value)">
    </form>
    <ul>
      <li *ngFor="let user of users$ | async">{{ user.login }}</li>
    </ul>
  `
})
class AppComponent implements OnInit {

  constructor(private http: HttpClient) {}

  users$: Observable<any[]> = this.http.get(`https://api.github.com/search/users?q=torvalds`).pipe(
    map(res => res['items'])
  )

  ngOnInit() {
    const search$ = this.search$.pipe(
      startWith('')
    )

    this.users$ = createWrapper(ng => {
      return this.search$.pipe(
        startWith(''),
        withLatestFrom(of(1)),
        map(([term, i]) => `https://api.github.com/search/users?q=${term}&page=${i}`),
        ng.httpFetch(),
        map(res => res['items'])
      )
    })(this.search$)
  }
}

export default AppComponent

运行应用程序

现在我们可以启动更新的 Next.js 应用程序，运行以下命令：

npm run dev

然后打开浏览器，访问 http://localhost:3000，你应该能够看到 Search Github Users 输入框。

总结

在本文中，我们已经看到了如何使用 RxJS 和 Angular4 构建一个 Next.js 应用程序，自动加载数据。 RxJS 提供的工具和抽象使得我们能够轻松地管理复杂的数据流。最后，我们还介绍了如何使用 @zeit/next-rxjs å库来简化在 Next.js 中处理 RxJS 数据流的工作。

来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/653f561e7d4982a6eb8e1454