.publishReplay() on existing .publish() connectableObservable does not replay

[paulspiteri]

tested on 5.0.3 & 5.2.0

The below test should pass and does pass if publishedUnderlying$ is taken out.
It appears that a replaySubject() is not being used in this scenario - instead a regular subject from the publish(?) is being used.

A simply workaround is to add .map(x => x) directly before .publishReplay() to hide the connectableObservable.

import { Subject } from 'rxjs';

describe('rx test', () => {

  it('should replay even if published', () => {

    const underlying$: Subject<{}> = new Subject<{}>();

    const publishedUnderlying$ = underlying$.publish();
    const publishConnection = publishedUnderlying$.connect();

    const replayed$ = publishedUnderlying$.publishReplay();
    const replayConnection = replayed$.connect();

    underlying$.next({});

    let nextCount = 0;
    const sub = replayed$.subscribe((data: {}) => {
      nextCount++;
    });

    expect(nextCount).toBe(1);

    replayConnection.unsubscribe();
    publishConnection.unsubscribe();
    sub.unsubscribe();
  });
});

[trxcllnt]

Ah, I see what's happening. Will try to have a fix soon.

[trxcllnt]

@paulspiteri fixed in #2405

[raybooysen]

Thanks @trxcllnt

[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.