Returns a ConnectableObservable, which is a variety of Observable that waits until its connect method is called before it begins emitting items to those Observers that have subscribed to it.

Deprecation Notes

Will be removed in v8. Use the connectable observable, the connect operator or the share operator instead. See the overloads below for equivalent replacement examples of this operator's behaviors. Details: https://rxjs.dev/deprecations/multicasting

publish(): UnaryFunction<Observable<T>, ConnectableObservable<T>>

Parameters

There are no parameters.

Returns

UnaryFunction<Observable<T>, ConnectableObservable<T>>

publish(selector: (shared: Observable<T>) => O): OperatorFunction<T, ObservedValueOf<O>>

Parameters

selector

(shared: Observable<T>) => O

A function used to setup multicasting prior to automatic connection.

Returns

OperatorFunction<T, ObservedValueOf<O>>

Description

Makes a cold Observable hot

Examples

Make source$ hot by applying publish operator, then merge each inner observable into a single one and subscribe

import { zip, interval, of, map, publish, merge, tap } from 'rxjs';

const source$ = zip(interval(2000), of(1, 2, 3, 4, 5, 6, 7, 8, 9))
  .pipe(map(([, number]) => number));

source$
  .pipe(
    publish(multicasted$ =>
      merge(
        multicasted$.pipe(tap(x => console.log('Stream 1:', x))),
        multicasted$.pipe(tap(x => console.log('Stream 2:', x))),
        multicasted$.pipe(tap(x => console.log('Stream 3:', x)))
      )
    )
  )
  .subscribe();

// Results every two seconds
// Stream 1: 1
// Stream 2: 1
// Stream 3: 1
// ...
// Stream 1: 9
// Stream 2: 9
// Stream 3: 9

See Also

• publishLast
• publishReplay
• publishBehavior