Lines Matching refs:currentStream
106 CFReadStreamRef currentStream;
118 if (form->currentStream) {
119 CFReadStreamClose(form->currentStream);
120 CFReadStreamSetClient(form->currentStream, kCFStreamEventNone, 0, 0);
121 CFRelease(form->currentStream);
122 form->currentStream = 0;
147 form->currentStream = CFReadStreamCreateWithBytesNoCopy(0, reinterpret_cast<const UInt8*>(data), size, kCFAllocatorNull);
159 form->currentStream = CFReadStreamCreateWithFile(0, pathAsURL(path).get());
160 if (!form->currentStream) {
167 CFReadStreamSetProperty(form->currentStream, kCFStreamPropertyFileCurrentOffset, position.get());
176 CFReadStreamSetClient(form->currentStream, kCFStreamEventHasBytesAvailable | kCFStreamEventErrorOccurred | kCFStreamEventEndEncountered,
182 CFReadStreamScheduleWithRunLoop(form->currentStream, (*it)->runLoop(), (*it)->mode());
192 while (form->currentStream && !CFReadStreamOpen(form->currentStream)) {
205 newInfo->currentStream = 0;
258 while (form->currentStream) {
264 CFIndex bytesRead = CFReadStreamRead(form->currentStream, buffer, bytesToRead);
266 *error = CFReadStreamGetError(form->currentStream);
292 while (form->currentStream && CFReadStreamGetStatus(form->currentStream) == kCFStreamStatusAtEnd)
295 if (!form->currentStream) {
299 return CFReadStreamHasBytesAvailable(form->currentStream);
328 if (form->currentStream)
329 CFReadStreamScheduleWithRunLoop(form->currentStream, runLoop, runLoopMode);
337 if (form->currentStream)
338 CFReadStreamUnscheduleFromRunLoop(form->currentStream, runLoop, runLoopMode);
357 if (!form->currentStream)