import {EndlessReplaySubject} from 'rxmq/src/rx/endlessReplaySubject.js'

public class | source

EndlessReplaySubject

Extends:

rxjs~ReplaySubject → EndlessReplaySubject

EndlessReplaySubject extension of ReplaySubject. 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 ReplaySubject doc. The only difference is that EndlessReplaySubject never triggers '.complete()' and does not closes observers on errors (thus allowing to continuously dispatch them).

Method Summary

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

Public Methods

public complete(): void source

Dummy method override to prevent execution and Observable completion

Return:

void

public error(error: Error): void source

Override of error method that prevents stopping that Observer

Params:

Name	Type	Attribute	Description
error	Error		Error to be dispatched

Return:

void