670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
|
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
|
-
-
+
+
|
#endif
- (OFString *)tryReadLine
{
return [self tryReadLineWithEncoding: OFStringEncodingUTF8];
}
- (OFString *)tryReadTillDelimiter: (OFString *)delimiter
encoding: (OFStringEncoding)encoding
- (OFString *)tryReadUntilDelimiter: (OFString *)delimiter
encoding: (OFStringEncoding)encoding
{
const char *delimiterCString;
size_t j, delimiterLength, pageSize, bufferLength;
char *buffer, *readBuffer;
OFString *ret;
delimiterCString = [delimiter cStringWithEncoding: encoding];
|
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
|
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
|
-
+
-
-
+
+
-
-
+
+
-
-
+
+
-
+
-
-
+
+
|
}
_waitingForDelimiter = true;
return nil;
}
- (OFString *)readTillDelimiter: (OFString *)delimiter
- (OFString *)readUntilDelimiter: (OFString *)delimiter
{
return [self readTillDelimiter: delimiter
encoding: OFStringEncodingUTF8];
return [self readUntilDelimiter: delimiter
encoding: OFStringEncodingUTF8];
}
- (OFString *)readTillDelimiter: (OFString *)delimiter
encoding: (OFStringEncoding)encoding
- (OFString *)readUntilDelimiter: (OFString *)delimiter
encoding: (OFStringEncoding)encoding
{
OFString *ret = nil;
while ((ret = [self tryReadTillDelimiter: delimiter
encoding: encoding]) == nil)
while ((ret = [self tryReadUntilDelimiter: delimiter
encoding: encoding]) == nil)
if (self.atEndOfStream)
return nil;
return ret;
}
- (OFString *)tryReadTillDelimiter: (OFString *)delimiter
- (OFString *)tryReadUntilDelimiter: (OFString *)delimiter
{
return [self tryReadTillDelimiter: delimiter
encoding: OFStringEncodingUTF8];
return [self tryReadUntilDelimiter: delimiter
encoding: OFStringEncodingUTF8];
}
- (bool)flushWriteBuffer
{
size_t bytesWritten;
if (_writeBuffer == NULL)
|