how to setup an rxjs subject in typescript

index.ts
import { Subject, Observable } from 'rxjs';
44 chars
2 lines

index.ts
const mySubject = new Subject();
33 chars
2 lines

index.ts
mySubject.subscribe({
  next: (data) => {
    console.log('Received data:', data);
  },
  error: (error) => {
    console.error('Error occurred:', error);
  },
  complete: () => {
    console.log('Subject completed!');
  }
});
227 chars
12 lines

index.ts
mySubject.next('Hello, world!');
33 chars
2 lines

index.ts
const subscription = mySubject.subscribe(/* ... */);

// Later on...
subscription.unsubscribe();
97 chars
5 lines