import {
  DestroyContainer,
  Message,
  MessageType,
  ResetSilenceCache,
} from "silentium";

/**
 * Active polling of $base message
 * synchronized with $trigger message
 * can return same values
 */
export function Polling<T>(
  $base: MessageType<T>,
  $trigger: MessageType<unknown>,
) {
  return Message<T>(function PollingImpl(resolve, reject) {
    const dc = DestroyContainer();
    $trigger
      .then(function pollingTriggerSub() {
        dc.destroy();
        resolve(ResetSilenceCache as T);
        dc.add($base.then(resolve).catch(reject));
      })
      .catch(reject);
  });
}