feat: add @rxjs/observable package and update rxjs to use it

.eslintignore

@@ -0,0 +1 @@
+packages/rxjs/integration/import/fixtures

.eslintrc.json

@@ -0,0 +1,45 @@
+{
+  "root": true,
+  "ignorePatterns": ["**/*"],
+  "plugins": ["@nx"],
+  "overrides": [
+    {
+      "files": ["*.ts", "*.tsx"],
+      "extends": ["plugin:@nx/typescript"],
+      "rules": {
+        "@typescript-eslint/no-explicit-any": "off",
+        "@typescript-eslint/no-unsafe-declaration-merging": "off",
+        "@typescript-eslint/consistent-type-imports": "warn",
+        "@typescript-eslint/consistent-type-exports": "warn",
+        "no-prototype-builtins": "off",
+        "@typescript-eslint/no-inferrable-types": "warn",
+        "@typescript-eslint/no-empty-function": "off",
+        "@typescript-eslint/no-empty-interface": "off"
+      }
+    },
+    {
+      "files": ["*.js", "*.jsx"],
+      "extends": ["plugin:@nx/javascript"],
+      "rules": {}
+    },
+    {
+      "files": ["*.ts", "*.tsx", "*.js", "*.jsx"],
+      "rules": {
+        "@nx/enforce-module-boundaries": [
+          "error",
+          {
+            "enforceBuildableLibDependency": true,
+            "allow": [],
+            "depConstraints": [
+              {
+                "sourceTag": "*",
+                "onlyDependOnLibsWithTags": ["*"]
+              }
+            ]
+          }
+        ],
+        "@typescript-eslint/no-unused-vars": "off"
+      }
+    }
+  ]
+}

.github/workflows/ci_main.yml

@@ -24,6 +24,9 @@ jobs:
         with:
           node-version: ${{ matrix.node }}
 
+      - name: Build, test and lint all projects (except website)
+        run: yarn nx run-many -t build lint test --exclude=rxjs.dev
+
       - name: rxjs lint
         run: yarn workspace rxjs lint
       - name: rxjs build

.github/workflows/ci_ts_latest.yml

@@ -27,4 +27,4 @@ jobs:
       - name: build
         run: |
           yarn workspace rxjs add typescript@latest @types/node@latest --peer --no-save
-          yarn workspace rxjs compile
+          yarn nx compile rxjs

.gitignore

@@ -12,6 +12,7 @@ typings/
 
 # Generated
 dist/
+.tshy-build
 
 # Import location artifacts
 packages/rxjs/ajax/

apps/rxjs.dev/package.json

@@ -142,5 +142,10 @@
     "xregexp": "^4.0.0",
     "yamljs": "^0.3.0",
     "yargs": "^13.2.4"
+  },
+  "nx": {
+    "implicitDependencies": [
+      "rxjs"
+    ]
   }
 }

nx.json

@@ -6,14 +6,41 @@
   "targetDefaults": {
     "build": {
       "dependsOn": ["^build"],
+      "inputs": ["production", "^production"],
       "cache": true
     },
     "test:circular": {
       "dependsOn": ["build"]
+    },
+    "test": {
+      "cache": true
+    },
+    "lint": {
+      "inputs": ["default", "{workspaceRoot}/.eslintrc.json", "{workspaceRoot}/tools/eslint-rules/**/*"],
+      "cache": true
     }
   },
+  "namedInputs": {
+    "default": ["{projectRoot}/**/*", "sharedGlobals"],
+    "production": ["default", "!{projectRoot}/**/?(*.)+(spec|test).[jt]s?(x)?(.snap)", "!{projectRoot}/.eslintrc.json"],
+    "sharedGlobals": [
+      "{workspaceRoot}/github/workflows/*.yml",
+      {
+        "runtime": "node -e 'console.log(`${process.platform}-${process.arch}`)'"
+      },
+      {
+        "runtime": "node --version"
+      },
+      {
+        "runtime": "npm --version"
+      },
+      {
+        "runtime": "yarn --version"
+      }
+    ]
+  },
   "release": {
-    "projects": ["rxjs"],
+    "projects": ["packages/*"],
     "releaseTagPattern": "{version}",
     "changelog": {
       "workspaceChangelog": {

package.json

@@ -1,9 +1,8 @@
 {
-  "name": "rxjs",
   "private": true,
   "workspaces": {
     "packages": [
-      "packages/rxjs",
+      "packages/*",
       "apps/rxjs.dev"
     ],
     "nohoist": [
@@ -19,12 +18,43 @@
   },
   "packageManager": "yarn@1.22.21",
   "scripts": {
-    "prepare-packages": "yarn nx run-many -t build,lint,test:circular,dtslint,copy_common_package_files --exclude rxjs.dev",
+    "prepare-packages": "yarn nx test @rxjs/observable && yarn nx run-many -t build,lint,test:circular,dtslint,copy_common_package_files --exclude rxjs.dev",
     "release": "node scripts/release.js"
   },
-  "dependencies": {},
   "devDependencies": {
-    "@nx/js": "17.3.0-beta.4",
-    "nx": "17.3.0-beta.4"
+    "@nx/eslint-plugin": "17.3.2",
+    "@nx/js": "17.3.2",
+    "@typescript-eslint/eslint-plugin": "^6.19.0",
+    "@typescript-eslint/parser": "^6.19.0",
+    "cz-conventional-changelog": "1.2.0",
+    "eslint": "^8.56.0",
+    "husky": "^4.2.5",
+    "lint-staged": "^10.2.11",
+    "nx": "17.3.2",
+    "ts-node": "^10.9.2",
+    "tshy": "^1.11.0",
+    "typescript": "~5.3.3",
+    "validate-commit-msg": "2.14.0",
+    "vitest": "^1.2.1"
+  },
+  "husky": {
+    "hooks": {
+      "pre-commit": "lint-staged",
+      "commit-msg": "validate-commit-msg"
+    }
+  },
+  "config": {
+    "commitizen": {
+      "path": "cz-conventional-changelog"
+    }
+  },
+  "lint-staged": {
+    "*.js": "eslint --cache --fix",
+    "(src|spec)/**/*.ts": [
+      "eslint --fix",
+      "prettier --write"
+    ],
+    "*.{js,css,md}": "prettier --write"
   }
 }
+

packages/observable/.eslintrc.json

@@ -0,0 +1,28 @@
+{
+  "extends": ["../../.eslintrc.json"],
+  "ignorePatterns": ["!**/*"],
+  "overrides": [
+    {
+      "files": ["*.ts", "*.tsx", "*.js", "*.jsx"],
+      "parserOptions": {
+        "project": ["./packages/observable/tsconfig.json"]
+      },
+      "rules": {}
+    },
+    {
+      "files": ["*.ts", "*.tsx"],
+      "rules": {}
+    },
+    {
+      "files": ["*.js", "*.jsx"],
+      "rules": {}
+    },
+    {
+      "files": ["./package.json"],
+      "parser": "jsonc-eslint-parser",
+      "rules": {
+        "@nx/dependency-checks": ["error"]
+      }
+    }
+  ]
+}

packages/observable/.tshy/browser.json

@@ -0,0 +1,12 @@
+{
+  "extends": "./build.json",
+  "include": [
+    "../src/**/*.ts",
+    "../src/**/*.mts",
+    "../src/**/*.tsx"
+  ],
+  "exclude": [],
+  "compilerOptions": {
+    "outDir": "../.tshy-build/browser"
+  }
+}

packages/observable/.tshy/build.json

@@ -0,0 +1,9 @@
+{
+  "extends": "../tsconfig.json",
+  "compilerOptions": {
+    "rootDir": "../src",
+    "target": "es2022",
+    "module": "nodenext",
+    "moduleResolution": "nodenext"
+  }
+}

packages/observable/.tshy/commonjs.json

@@ -0,0 +1,14 @@
+{
+  "extends": "./build.json",
+  "include": [
+    "../src/**/*.ts",
+    "../src/**/*.cts",
+    "../src/**/*.tsx"
+  ],
+  "exclude": [
+    "../src/**/*.mts"
+  ],
+  "compilerOptions": {
+    "outDir": "../.tshy-build/commonjs"
+  }
+}

packages/observable/.tshy/esm.json

@@ -0,0 +1,12 @@
+{
+  "extends": "./build.json",
+  "include": [
+    "../src/**/*.ts",
+    "../src/**/*.mts",
+    "../src/**/*.tsx"
+  ],
+  "exclude": [],
+  "compilerOptions": {
+    "outDir": "../.tshy-build/esm"
+  }
+}

packages/observable/.tshy/webpack.json

@@ -0,0 +1,14 @@
+{
+  "extends": "./build.json",
+  "include": [
+    "../src/**/*.ts",
+    "../src/**/*.cts",
+    "../src/**/*.tsx"
+  ],
+  "exclude": [
+    "../src/**/*.mts"
+  ],
+  "compilerOptions": {
+    "outDir": "../.tshy-build/webpack"
+  }
+}

packages/observable/package.json

@@ -0,0 +1,70 @@
+{
+  "name": "@rxjs/observable",
+  "version": "8.0.0-alpha.14",
+  "license": "Apache-2.0",
+  "bugs": {
+    "url": "https://github.com/ReactiveX/RxJS/issues"
+  },
+  "homepage": "https://rxjs.dev",
+  "author": "Ben Lesh <ben@benlesh.com>",
+  "files": [
+    "dist"
+  ],
+  "main": "./dist/commonjs/index.js",
+  "types": "./dist/commonjs/index.d.ts",
+  "type": "module",
+  "scripts": {
+    "build": "tshy",
+    "lint": "eslint ./src",
+    "test": "vitest --run",
+    "test:watch": "vitest"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/ReactiveX/rxjs.git",
+    "directory": "packages/observable"
+  },
+  "keywords": [
+    "Rx",
+    "RxJS",
+    "ReactiveX",
+    "ReactiveExtensions",
+    "Streams",
+    "Observables",
+    "Observable",
+    "Stream"
+  ],
+  "tshy": {
+    "exports": {
+      "./package.json": "./package.json",
+      ".": "./src/index.ts"
+    },
+    "esmDialects": [
+      "browser"
+    ],
+    "commonjsDialects": [
+      "webpack"
+    ]
+  },
+  "exports": {
+    "./package.json": "./package.json",
+    ".": {
+      "browser": {
+        "types": "./dist/browser/index.d.ts",
+        "default": "./dist/browser/index.js"
+      },
+      "webpack": {
+        "types": "./dist/webpack/index.d.ts",
+        "default": "./dist/webpack/index.js"
+      },
+      "import": {
+        "types": "./dist/esm/index.d.ts",
+        "default": "./dist/esm/index.js"
+      },
+      "require": {
+        "types": "./dist/commonjs/index.d.ts",
+        "default": "./dist/commonjs/index.js"
+      }
+    }
+  }
+}

packages/observable/src/index.ts

@@ -0,0 +1,18 @@
+export { Observable, Subscriber, Subscription, UnsubscriptionError, config, from, isObservable, operate } from './observable.js';
+export type { GlobalConfig, SubscriberOverrides } from './observable.js';
+
+// TODO: reevaluate these as part of public API of @rxjs/observable? They aren't exported from rxjs so feel more internal?
+export {
+  COMPLETE_NOTIFICATION,
+  ObservableInputType,
+  createNotification,
+  errorNotification,
+  fromArrayLike,
+  getObservableInputType,
+  isArrayLike,
+  isFunction,
+  isPromise,
+  nextNotification,
+  readableStreamLikeToAsyncGenerator,
+  subscribeToArray,
+} from './observable.js';