<commit_before>import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Rx';
import { ReplaySubject } from 'rxjs/ReplaySubject';
import { WorkerMessage, ProcessMessage, ProcessTaskRegistration, ProcessRoutine } from '../index';

export class Message {
  constructor(
    public show: boolean = false,
    public message: string = '',
    public alert: string = 'info'
  ) {}
}

/**
 * This class provides the NameList service with methods to read names and add names.
 */
@Injectable()
export class MessageService {

// Add Notices, messages that must be dismissed. Notices stack.

    public flashMessage: ReplaySubject<any> = new ReplaySubject();
    public processMessage: ReplaySubject<any> = new ReplaySubject(1);
    public stickyMessage: ReplaySubject<any> = new ReplaySubject(1);
    public workerQueue: ReplaySubject<any> = new ReplaySubject();
    public processInitQueue: ReplaySubject<any> = new ReplaySubject();
    public processQueue: ReplaySubject<any> = new ReplaySubject();
    public registrarQueue: ReplaySubject<any> = new ReplaySubject();

    public setFlash(message:string, alert:string = 'info') {
        let flashMessage = new Message(true,message,alert);
        this.flashMessage.next(flashMessage);
        var control = Observable.timer(3000);
        control.subscribe(x => flashMessage.show = false);
    }

    public addProcessMessage(message:string, alert:string = 'info') {
        let processMessage = new Message(true,message,alert);
        this.processMessage.next(processMessage);
        var control = Observable.timer(3000);
        control.subscribe(x => processMessage.show = false);
    }

    public addStickyMessage(message:string, alert:string = 'info') {
        let stickyMessage = new Message(true,message,alert);
        this.stickyMessage.next(stickyMessage);
    }

    public processSignal(message: WorkerMessage) {
        this.workerQueue.next(message);
    }

    public startProcess(routine: string, params: {}) {
        this.processInitQueue.next(new ProcessMessage(routine,params));
    }

    public continueProcess(process: ProcessRoutine) {
        this.processQueue.next(process);
    }

    public getFlashMessage(): ReplaySubject<any> {
        return this.flashMessage;
    }

    public getStickyMessageRelay(): ReplaySubject<any> {
        return this.stickyMessage;
    }

    public getProcessMessageRelay(): ReplaySubject<any> {
        return this.processMessage;
    }

    public getWorkerQueue(): ReplaySubject<any> {
        return this.workerQueue;
    }

    public getProcessQueue(): ReplaySubject<any> {
        return this.processQueue;
    }

    public getProcessInitQueue(): ReplaySubject<any> {
        return this.processInitQueue;
    }

    public getRegistrarQueue(): ReplaySubject<any> {
        return this.registrarQueue;
    }

    public registerProcessTasks(processTaskRegistration: ProcessTaskRegistration) {
        this.registrarQueue.next(processTaskRegistration);
    }

}
<commit_msg>Remove unused message service methods<commit_after>import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Rx';
import { ReplaySubject } from 'rxjs/ReplaySubject';
import { WorkerMessage, ProcessMessage, ProcessTaskRegistration, ProcessRoutine } from '../index';

export class Message {
  constructor(
    public show: boolean = false,
    public message: string = '',
    public alert: string = 'info'
  ) {}
}

/**
 * This class provides the NameList service with methods to read names and add names.
 */
@Injectable()
export class MessageService {

// Add Notices, messages that must be dismissed. Notices stack.

    public flashMessage: ReplaySubject<any> = new ReplaySubject();
    public processMessage: ReplaySubject<any> = new ReplaySubject(1);
    public stickyMessage: ReplaySubject<any> = new ReplaySubject(1);
    public workerQueue: ReplaySubject<any> = new ReplaySubject();
    public processInitQueue: ReplaySubject<any> = new ReplaySubject();
    public processQueue: ReplaySubject<any> = new ReplaySubject();
    public registrarQueue: ReplaySubject<any> = new ReplaySubject();

    public setFlash(message:string, alert:string = 'info') {
        let flashMessage = new Message(true,message,alert);
        this.flashMessage.next(flashMessage);
        var control = Observable.timer(3000);
        control.subscribe(x => flashMessage.show = false);
    }

    public addProcessMessage(message:string, alert:string = 'info') {
        let processMessage = new Message(true,message,alert);
        this.processMessage.next(processMessage);
        var control = Observable.timer(3000);
        control.subscribe(x => processMessage.show = false);
    }

    public addStickyMessage(message:string, alert:string = 'info') {
        let stickyMessage = new Message(true,message,alert);
        this.stickyMessage.next(stickyMessage);
    }

    public startProcess(routine: string, params: {}) {
        this.processInitQueue.next(new ProcessMessage(routine,params));
    }

    public continueProcess(process: ProcessRoutine) {
        this.processQueue.next(process);
    }

    public getFlashMessage(): ReplaySubject<any> {
        return this.flashMessage;
    }

    public getStickyMessageRelay(): ReplaySubject<any> {
        return this.stickyMessage;
    }

    public getProcessMessageRelay(): ReplaySubject<any> {
        return this.processMessage;
    }

    public getProcessQueue(): ReplaySubject<any> {
        return this.processQueue;
    }

    public getProcessInitQueue(): ReplaySubject<any> {
        return this.processInitQueue;
    }

    public getRegistrarQueue(): ReplaySubject<any> {
        return this.registrarQueue;
    }

    public registerProcessTasks(processTaskRegistration: ProcessTaskRegistration) {
        this.registrarQueue.next(processTaskRegistration);
    }

}

{'fraction_non_alphanumeric': 0.10467896174863388, 'fraction_numerical': 0.0034153005464480873, 'mean_word_length': 3.719580983078163, 'pattern_counts': {'":': 0, '<': 30, '<?xml version=': 0, '>': 34, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2227370', 'n_tokens_mistral': 1627, 'n_tokens_neox': 1582, 'n_words': 371}