以下是一个使用Angular和RxJS的示例代码，其中包括OnInit和搜索功能：

1. 创建一个名为"search.component.ts"的组件文件：

import { Component, OnInit } from '@angular/core';
import { Observable, Subject } from 'rxjs';
import { debounceTime, distinctUntilChanged, switchMap } from 'rxjs/operators';

import { DataService } from './data.service';

@Component({
  selector: 'app-search',
  templateUrl: './search.component.html',
  styleUrls: ['./search.component.css']
})
export class SearchComponent implements OnInit {
  searchResults$: Observable;
  private searchTerms = new Subject();

  constructor(private dataService: DataService) { }

  ngOnInit() {
    this.searchResults$ = this.searchTerms.pipe(
      debounceTime(300),
      distinctUntilChanged(),
      switchMap(term => this.dataService.search(term))
    );
  }

  search(term: string): void {
    this.searchTerms.next(term);
  }
}

2. 创建一个名为"data.service.ts"的服务文件，用于模拟搜索功能：

import { Injectable } from '@angular/core';
import { Observable, of } from 'rxjs';

@Injectable({
  providedIn: 'root'
})
export class DataService {
  search(term: string): Observable {
    // 在这里进行实际的搜索操作，例如向后端API发送HTTP请求
    // 这里只是模拟返回一些假数据
    const fakeData = [
      { id: 1, name: 'Result 1' },
      { id: 2, name: 'Result 2' },
      { id: 3, name: 'Result 3' }
    ];
    return of(fakeData.filter(item => item.name.includes(term)));
  }
}

3. 创建一个名为"search.component.html"的模板文件：

  
{{ result.name }}

在这个示例中，我们在search.component.ts中定义了一个Observable对象"searchResults$"，它将接收到的搜索词转换为Observable流。我们使用debounceTime操作符来限制搜索请求的频率，distinctUntilChanged操作符来确保只在搜索词发生变化时发送请求，switchMap操作符将搜索词映射为实际的搜索操作，这里是调用data.service.ts中的search方法。最后，我们在search.component.html中使用async管道来订阅并显示搜索结果。

你可以在这个基础上进行扩展，如添加错误处理、自动完成等功能。