import { BehaviorSubject, Observable } from 'rxjs';
import { EventEmitter } from '@angular/core';

export class EventInputManager<T> {
  private stateSubject: BehaviorSubject<T | null>;
  state$: Observable<T | null>;

  constructor(
    initialValue: T | null,
    private eventEmitter: EventEmitter<T>
  ) {
    this.stateSubject = new BehaviorSubject<T | null>(initialValue);
    this.state$ = this.stateSubject.asObservable();
  }

  /**
   * Update the value and emit the event.
   */
  next(newValue: T): void {
    this.stateSubject.next(newValue); // Update state
    if (this.eventEmitter) {
      this.eventEmitter.emit(newValue); // Emit event
    }
  }

  /**
   * Get the current value.
   */
  get value(): T | null {
    return this.stateSubject.value;
  }
}