streamcorpus_pipeline/_spinn3r_feed_storage.py
def _read(self, n):
        """Read (up to) 'n' bytes from the underlying file.  If any bytes
        have been pushed in with _unread() those are returned first."""
        if n <= len(self._prefix):
            # the read can be fulfilled entirely from the prefix
            result = self._prefix[:n]
            self._prefix = self._prefix[n:]
            return result
        # otherwise we need to read some
        n -= len(self._prefix)
        result = self._prefix + self.f.read(n)
        self._prefix = ""
        return result
def _read(self, n):
        """Read (up to) 'n' bytes from the underlying file.  If any bytes
        have been pushed in with _unread() those are returned first."""
        if n <= len(self._prefix):
            # the read can be fulfilled entirely from the prefix
            result = self._prefix[:n]
            self._prefix = self._prefix[n:]
            return result
        # otherwise we need to read some
        n -= len(self._prefix)
        result = self._prefix + self.f.read(n)
        self._prefix = ""
        return result
def _read ( self , n ) : if n <= len ( self . _prefix ) : # the read can be fulfilled entirely from the prefix result = self . _prefix [ : n ] self . _prefix = self . _prefix [ n : ] return result # otherwise we need to read some n -= len ( self . _prefix ) result = self . _prefix + self . f . read ( n ) self . _prefix = "" return result
Read (up to) 'n' bytes from the underlying file.  If any bytes
        have been pushed in with _unread() those are returned first.
Read ( up to ) n bytes from the underlying file . If any bytes have been pushed in with _unread () those are returned first .