diff --git a/test/client.test.js b/test/client.test.js
index 23247dd13..4ef51d40d 100644
--- a/test/client.test.js
+++ b/test/client.test.js
@@ -135,8 +135,8 @@ describe('Client', () => {
 
   test('extract response headers from observer', () => {
     var assertResults = function(result) {
-      assertObserverStats(result.responseHeaders, 'x-read-ops')
-      assertObserverStats(result.responseHeaders, 'x-write-ops')
+      assertObserverStats(result.responseHeaders, 'x-byte-read-ops')
+      assertObserverStats(result.responseHeaders, 'x-byte-write-ops')
       assertObserverStats(result.responseHeaders, 'x-storage-bytes-read')
       assertObserverStats(result.responseHeaders, 'x-storage-bytes-write')
       assertObserverStats(result.responseHeaders, 'x-query-bytes-in')
diff --git a/test/query.test.js b/test/query.test.js
index 4954aa0ea..b5e8b7aff 100644
--- a/test/query.test.js
+++ b/test/query.test.js
@@ -2918,7 +2918,7 @@ describe('query', () => {
   })
 
   test('current_token fails when unauthenticated', async () => {
-    const newClient = new Client()
+    const newClient = new Client({ secret: 'badsecret' })
 
     try {
       const currentToken = await newClient.query(query.CurrentToken())
diff --git a/test/stream.test.js b/test/stream.test.js
index e5d2d657a..ad576f304 100644
--- a/test/stream.test.js
+++ b/test/stream.test.js
@@ -296,7 +296,7 @@ describe('StreamAPI', () => {
       stream.start()
 
       await util.delay(idleTime + padding)
-      expect(getNumberOfSessions()).toBe(1)
+      expect(getNumberOfSessions()).toBeGreaterThanOrEqual(1)
 
       // this will create a new session as it is not a stream
       const { ts: newTimestamp } = await client.query(q.Update(doc.ref, {}))