import { DataSource } from '@angular/cdk/collections'; import { Observable } from 'rxjs'; export class BillsDataSource extends DataSource { constructor(private data: Observable ) { super(); } connect(): Observable { return this.data; } /** * Called when the table is being destroyed. Use this function, to clean up * any open connections or free any held resources that were set up during connect. */ disconnect() { } }