Qwik + RxJs

index.tsx

import {
  component$,
  useSignal,
  $,
} from "@builder.io/qwik"
import { loader$, DocumentHead } from "@builder.io/qwik-city"
import { scan, Subject } from "rxjs"

export const timeLoader = loader$(() => new Date())

export default component$(() => {
  const count = useSignal(0)
  const now = timeLoader.use()
  const ctrl = $(
    useSubject<null>((s) => {
      s.pipe(scan((count) => count + 1, 0)).subscribe((count) =>
        alert(`Clicked ${count} times`)
      )
    })
  )

  return (
    <a>
      Now: {now.value.toISOString()}
      {count.value}
      <button onClick$={async () => (await ctrl.resolve()).next(null)}>
        +
      </button>
    </a>
  )
})

export const head: DocumentHead = {
  title: "RxJs test",
}

export function useSubject<T>(fn: (subject: Subject<T>) => void): Subject<T> {
  const subject = new Subject<null>()
  fn(subject)
  return subject
}