import type { SFPToolboxError } from '../../error/error';

export class ProbeEmitter {
  subscriptor: any;
  savedError: any;
  subscribe(aSubscriptor) {
    this.subscriptor = aSubscriptor;
  }

  emit(aString) {
    this.subscriptor.appendString(aString);
  }

  cancel(_aReason) {
    throw new Error('Not implemented');
  }

  error(anErrorObject: SFPToolboxError) {
    this.savedError = anErrorObject;
    this.cancel('');
    this.subscriptor?.reject(anErrorObject);
  }

  cancelPendingTransactions() {}

  start(_command: string, _mockCode?: string) {}
}