fix(deps): upgrade rxjs to v7 (#80)

package.json

@@ -53,7 +53,7 @@
     "@sanity/eventsource": "^4.0.0",
     "get-it": "^7.0.2",
     "make-error": "^1.3.6",
-    "rxjs": "^6.6.7"
+    "rxjs": "^7.0.0"
   },
   "devDependencies": {
     "@babel/cli": "^7.20.7",

src/assets/assetsClient.js

@@ -1,6 +1,6 @@
-import {map, filter} from '../util/observable'
 import queryString from '../http/queryString'
 import * as validators from '../validators'
+import {filter, map} from 'rxjs/operators'
 
 function AssetsClient(client) {
   this.client = client

src/data/dataMethods.js

@@ -1,10 +1,10 @@
-import {map, filter} from '../util/observable'
 import * as validators from '../validators'
 import getSelection from '../util/getSelection'
 import encodeQueryString from './encodeQueryString'
 import Transaction from './transaction'
 import Patch from './patch'
 import listen from './listen'
+import {filter, map} from 'rxjs/operators'
 
 const excludeFalsey = (param, defValue) => {
   const value = typeof param === 'undefined' ? defValue : param

src/data/listen.js

@@ -1,8 +1,8 @@
-import {Observable} from '../util/observable'
 import polyfilledEventSource from '@sanity/eventsource'
 import pick from '../util/pick'
 import defaults from '../util/defaults'
 import encodeQueryString from './encodeQueryString'
+import {Observable} from 'rxjs'
 
 // Limit is 16K for a _request_, eg including headers. Have to account for an
 // unknown range of headers, but an average EventSource request from Chrome seems

src/http/request.js

@@ -1,9 +1,9 @@
 /* eslint-disable no-empty-function, no-process-env */
 import getIt from 'get-it'
 import {observable, jsonRequest, jsonResponse, progress} from 'get-it/middleware'
-import {Observable} from '../util/observable'
 import {ClientError, ServerError} from './errors'
 import envMiddleware from './nodeMiddleware'
+import {Observable} from 'rxjs'
 
 const httpError = {
   onResponse: (res) => {

src/sanityClient.js

@@ -1,4 +1,3 @@
-import {Observable, map, filter} from './util/observable'
 import Patch from './data/patch'
 import Transaction from './data/transaction'
 import dataMethods from './data/dataMethods'
@@ -11,8 +10,8 @@ import httpRequest from './http/request'
 import getRequestOptions from './http/requestOptions'
 import {defaultConfig, initConfig} from './config'
 import * as validate from './validators'
-
-const toPromise = (observable) => observable.toPromise()
+import {lastValueFrom, Observable} from 'rxjs'
+import {filter, map} from 'rxjs/operators'
 
 function SanityClient(config = defaultConfig) {
   if (!(this instanceof SanityClient)) {
@@ -111,7 +110,7 @@ Object.assign(SanityClient.prototype, {
       map((event) => event.body)
     )
 
-    return this.isPromiseAPI() ? toPromise(observable) : observable
+    return this.isPromiseAPI() ? lastValueFrom(observable) : observable
   },
 })