import {EndlessSubject} from 'rxmq/src/rx/endlessSubject.js'

public class | source

EndlessSubject

Extends:

rxjs~Subject → EndlessSubject

EndlessSubject extension of Rx.Subject. This is pretty hacky, but so far I'd found no better way of having Subjects that do no close on multicasted stream completion and on multiple errors. For documentation refer to Rx.Subject docs. The only difference is that EndlessSubject never triggers '.complete()' and does not closes observers on errors (thus allowing to continuously dispatch them).

Member Summary

Public Members
public	thrownError: *

Method Summary

Public Methods
public	complete(): void Dummy method override to prevent execution and Rx.Observable completion
public	error(error: Error): void Override of error method that prevents stopping that Rx.Observer

Public Members

public thrownError: * source

Public Methods

public complete(): void source

Dummy method override to prevent execution and Rx.Observable completion

Return:

void

public error(error: Error): void source

Override of error method that prevents stopping that Rx.Observer

Params:

Name	Type	Attribute	Description
error	Error		Error to be dispatched

Return:

void