rxjs-expermient.ts

import { BehaviorSubject, Subject, Observable, of, interval } from 'rxjs';
import { delay, map, take, tap, timeout } from 'rxjs/operators';

function PostLogin(): Observable<number> {
    return interval(1000).pipe(take(1), map(() => 200));
}


class LoginService {

    public async performLogin() {
        console.log('BOF1');
        const result = await this.performLogin$().pipe(timeout(5000)).toPromise();
        console.log('done!');
        console.log('EOF1');
    }

    public performLoginSubscribe() {
        console.log('BOF2');
        this.performLogin$().subscribe(() => {
            console.log('done!')
            console.log('EOF2')
        });
    }

    private performLogin$(): Observable<{ code: number }> {
        return PostLogin().pipe(
            map(code => ({ code })),
        );
    }

}

async function start() {
    const loginService = new LoginService();
    await loginService.performLogin()
    console.log('End of main')
}
start();