support rxjs 7

Author: insidewhy

changelog.md

@@ -1,5 +1,7 @@
 # Changelog
 
+- 2021/07/19 - 9.0.0
+  - Support rxjs 7
 - 2020/03/20 - 8.0.1
   - Ensure `close` is called even when the `open` event is not received.
 - 2019/09/22 - 8.0.0

package.json

@@ -1,7 +1,7 @@
 {
   "name": "rxjs-websockets",
-  "version": "8.0.1",
-  "description": "rxjs 6 websockets library",
+  "version": "9.0.0",
+  "description": "rxjs 7 websockets library",
   "author": "insidewhy <[email protected]>",
   "license": "ISC",
   "repository": {
@@ -42,21 +42,21 @@
     "jest-watch": "yarn jest --watch"
   },
   "peerDependencies": {
-    "rxjs": "^6.1.0"
+    "rxjs": "^7.0.0"
   },
   "devDependencies": {
-    "@types/jest": "25.2.1",
-    "@typescript-eslint/eslint-plugin": "2.34.0",
-    "@typescript-eslint/parser": "2.34.0",
-    "concurrently": "5.1.0",
-    "eslint": "6.8.0",
-    "eslint-config-prettier": "6.12.0",
-    "husky": "4.2.5",
-    "jest": "27.0.4",
-    "prettier": "2.0.4",
-    "pretty-quick": "3.0.2",
+    "@types/jest": "26.0.24",
+    "@typescript-eslint/eslint-plugin": "4.28.3",
+    "@typescript-eslint/parser": "4.28.3",
+    "concurrently": "6.2.0",
+    "eslint": "7.31.0",
+    "eslint-config-prettier": "8.3.0",
+    "husky": "7.0.1",
+    "jest": "27.0.6",
+    "prettier": "2.3.2",
+    "pretty-quick": "3.1.1",
     "rimraf": "3.0.2",
-    "rxjs": "6.6.3",
-    "typescript": "4.0.3"
+    "rxjs": "^7.2.0",
+    "typescript": "4.3.5"
   }
 }

readme.md

@@ -24,6 +24,14 @@ npm install -S rxjs-websockets
 yarn add rxjs-websockets
 ```
 
+For rxjs 6 support, rxjs-websockets 8 is needed.
+
+```bash
+npm install -S rxjs-websockets@8
+# or
+yarn add rxjs-websockets@8
+```
+
 ## Changelog
 
 [Changelog here](changelog.md)
@@ -155,10 +163,11 @@ function makeJsonWebSocketObservable(
 ): Observable<unknown> {
   const socket$ = makeWebSocketObservable<string>(url, options)
   return socket$.pipe(
-    map((getResponses: GetWebSocketReponses<string>) => (input$: Observable<object>) =>
-      getResponses(input$.pipe(map((request) => JSON.stringify(request)))).pipe(
-        map((response) => JSON.parse(response)),
-      ),
+    map(
+      (getResponses: GetWebSocketReponses<string>) => (input$: Observable<object>) =>
+        getResponses(input$.pipe(map((request) => JSON.stringify(request)))).pipe(
+          map((response) => JSON.parse(response)),
+        ),
     ),
   )
 }

src/index.spec.ts

@@ -1,7 +1,6 @@
 import { TestScheduler } from 'rxjs/testing'
-import { of } from 'rxjs'
+import { of, throwError } from 'rxjs'
 import { delay, catchError, switchMap } from 'rxjs/operators'
-import { throwError } from 'rxjs/internal/observable/throwError'
 
 import connect, { normalClosureMessage, WebSocketLike } from '.'