Incorrect AsyncSubject behaviour

[unao]

RxJS version: https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.0.0-beta.9/Rx.umd.js

Code to reproduce:

var subject = new Rx.AsyncSubject();

subject.next(1);
subject.complete();
subject.subscribe(v => console.log(v));

subject.next(2);
var sub = subject.subscribe(v => console.log(v));

PLNKR

Expected behavior:
subject.next(2) should have no effect.

Actual behavior:
It is possible to publish values after the stream completed.
1 is the result of the async computation and it should be used for any future subscribes.

Additional information:
afaik, it violates the Observable interface.

[unao]

This one is pretty interesting as well:

var subject = new Rx.AsyncSubject();

subject.asObservable().delay(0).subscribe(v => console.log('delayed', v));

subject.next(1);
subject.complete();
subject.subscribe(v => console.log(v));

subject.next(2);

subject.asObservable().subscribe(v => console.log(v));

PLNKR

[kwonoj]

indeed, seems current implementation missing guard to next when it's completed.

[lock]

This thread has been automatically locked since there has not been any recent activity after it was closed. Please open a new issue for related bugs.