837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
|
if (_decompressedStream == nil)
@throw [OFNotOpenException exceptionWithObject: self];
if (_atEndOfStream)
return 0;
if (_archive->_stream.atEndOfStream &&
!_decompressedStream.hasDataInReadBuffer) {
OFStream *oldStream, *oldDecompressedStream;
OFSeekableStream *stream;
if (_archive->_diskNumber >= _archive->_lastDiskNumber)
@throw [OFTruncatedDataException exception];
oldStream = _archive->_stream;
|
|
|
|
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
|
if (_decompressedStream == nil)
@throw [OFNotOpenException exceptionWithObject: self];
if (_atEndOfStream)
return 0;
if ([_archive->_stream isAtEndOfStream] &&
![_decompressedStream hasDataInReadBuffer]) {
OFStream *oldStream, *oldDecompressedStream;
OFSeekableStream *stream;
if (_archive->_diskNumber >= _archive->_lastDiskNumber)
@throw [OFTruncatedDataException exception];
oldStream = _archive->_stream;
|
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
|
return ret;
}
- (bool)hasDataInReadBuffer
{
return (super.hasDataInReadBuffer ||
_decompressedStream.hasDataInReadBuffer);
}
- (int)fileDescriptorForReading
{
return ((id <OFReadyForReadingObserving>)_decompressedStream)
.fileDescriptorForReading;
}
|
|
|
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
|
return ret;
}
- (bool)hasDataInReadBuffer
{
return (super.hasDataInReadBuffer ||
[_decompressedStream hasDataInReadBuffer]);
}
- (int)fileDescriptorForReading
{
return ((id <OFReadyForReadingObserving>)_decompressedStream)
.fileDescriptorForReading;
}
|