def get_stream(self, bucket, label, as_stream=True):
        if self.mode == "w":
            raise OFSException, "Cannot read from archive in 'w' mode"
        elif self.exists(bucket, label):
            fn = self._zf(bucket, label)
            if as_stream:
                return self.z.open(fn)
            else:
                return self.z.read(fn)
        else:
            raise OFSFileNotFound
Switches blocking sends, calls.
dataset/ETHPy150Open okfn/ofs/ofs/local/zipstore.py/ZOFS.get_stream--crossover with--dataset/ETHPy150Open philipbergen/zero/py/zero/__init__.py/ZeroSetup.nonblocking