import { fromEvent, Subject } from 'rxjs';import { map } from 'rxjs/operators';const emitButton = document.querySelector('button#emit');const inputElement: HTMLInputElement = document.querySelector('#value-input');const subscribeButton = document.querySelector('button#subscribe');const value$ = new Subject<string>();fromEvent(emitButton, 'click').subscribe(() => value$.next(inputElement.value));fromEvent(subscribeButton, 'click').subscribe(() => {  console.log('New Subscription');  value$.subscribe((value) => console.log(value));});

fromEvent(emitButton, 'click')  .pipe(map(() => inputElement.value))  .subscribe(value$);

import { BehaviorSubject, fromEvent, Subject } from "rxjs";import { withLatestFrom } from "rxjs/operators";const loggedInSpan: HTMLElement = document.querySelector('span#logged-in');const loginButton: HTMLElement = document.querySelector('button#login');const logoutButton: HTMLElement = document.querySelector('button#logout');const printStateButton: HTMLElement = document.querySelector('button#print-state');const isLoggedIn$ = new BehaviorSubject<boolean>(false);fromEvent(loginButton, 'click').subscribe(() => isLoggedIn$.next(true));fromEvent(logoutButton, 'click').subscribe(() => isLoggedIn$.next(false));// Navigation barisLoggedIn$.subscribe(  isLoggedIn => loggedInSpan.innerText = isLoggedIn.toString());// ButtonsisLoggedIn$.subscribe(isLoggedIn => {  logoutButton.style.display = isLoggedIn ? 'block' : 'none';  loginButton.style.display = !isLoggedIn ? 'block' : 'none';});fromEvent(printStateButton, 'click').pipe(  withLatestFrom(isLoggedIn$)).subscribe(  ([event, isLoggedIn]) => console.log('User is logged in:', isLoggedIn));