fixups

Author: blink1073

pymongo/network_layer.py

@@ -495,7 +495,7 @@ def data_received(self, data: bytes) -> None:
             return
 
         self._bytes_ready += len(data)
-        self._buffers.append(memoryview[data])
+        self._buffers.append(memoryview(data))
 
         if not len(self._pending_reads):
             return
@@ -505,9 +505,6 @@ def data_received(self, data: bytes) -> None:
         waiter = self._pending_listeners.popleft()
         waiter.set_result(data)
 
-    def eof_received(self):
-        self.close(OSError("connection closed"))
-
     async def read(self, bytes_needed: int) -> bytes:
         """Read up to the requested bytes from this connection."""
         # Note: all reads are "up-to" bytes_needed because we don't know if the kms_context
@@ -552,8 +549,9 @@ def _read(self, bytes_needed: int) -> memoryview:
             # if we didn't exhaust the buffer, read the partial data and return the buffer.
             if buf_size > n_remaining:
                 output_buf[out_index : n_remaining + out_index] = buffer[:n_remaining]
+                buffer = buffer[n_remaining:]
                 n_remaining = 0
-                self._buffers.appendleft(buffer[n_remaining:])
+                self._buffers.appendleft(buffer)
             # otherwise exhaust the buffer.
             else:
                 output_buf[out_index : out_index + buf_size] = buffer[:]