hunk.code_window: import { Subject } from '../Subject';
   import { Subscription } from '../Subscription';
   import { Observable } from '../Observable';
   import { defer } from './defer';
   /**
    * An observable with a `connect` method that is used to create a subscription
    * to an underlying source, connecting it with all consumers via a multicast.
    */
   export interface ConnectableObservableLike<T> extends Observable<T> {
     /**
      * (Idempotent) Calling this method will connect the underlying source observable to all subscribed consumers
      * through an underlying {@link Subject}.
      * @returns A subscription, that when unsubscribed, will "disconnect" the source from the connector subject,
      * severing notifications to all consumers.
      */
     connect(): Subscription;
   }
   export interface ConnectableConfig<T> {
     /**
      * A factory function used to create the Subject through which the source
      * is multicast. By default this creates a {@link Subject}.
      */
  
hunk.labels: keep keep keep keep keep replace replace replace replace replace replace replace replace replace replace replace replace replace replace keep keep keep keep keep
hunk.file_path: src/internal/observable/connectable.ts
hunk.type: replace
file: 
  module.exports = function copyContentAssetsProcessor(copyFolder) {
    return {
      $runBefore: ['postProcessHtml'],
      assetMappings: [],
      $process() {
        this.assetMappings.forEach(map => {
          copyFolder(map.from, map.to);
        });
      }
    };
  };
  