Function send

packages/core/rxjs-interop/src/rx_resource.ts:102–105

(value: ResourceStreamItem<T>)

      params.abortSignal.addEventListener('abort', onAbort);

      function send(value: ResourceStreamItem<T>): void {
        stream.set(value);
        resolveOnce();
      }

      const streamFn = opts.stream;
      if (streamFn === undefined) {