MyObjectDataSource.ts

export class MyObjectDatasourceService implements DataSource<MyObject> {
  
    private myObjectSubject = new BehaviorSubject<MyObject[]>([]);


    constructor(private myObjectService: MyObjectService){}

    connect(collectionViewer: CollectionViewer): Observable<MyObject[]> {
        return this.myObjectSubject.asObservable();
    }

    disconnect(collectionViewer: CollectionViewer): void {
        this.myObjectSubject.complete();
    }

    loadVentures() {
        this.myObjectService.fetchRemoteObjects()
        .pipe(
            catchError(() => of([]))
        )
        .subscribe ( myObjects => {
            this.myobjectSubject.next(myObjects);
        }
        );
    }
}