Lines Matching refs:pipe

161   GRXBufferedPipe *pipe = [GRXBufferedPipe pipe];
162   [pipe startWithWriteable:writeable];
163   [pipe writeValue:anyValue];
164   [pipe writesFinishedWithError:nil];
185   GRXBufferedPipe *pipe = [GRXBufferedPipe pipe];
186   [pipe startWithWriteable:writeable];
187   [pipe writesFinishedWithError:anyError];
208   GRXBufferedPipe *pipe = [GRXBufferedPipe pipe];
210   [pipe writeValue:anyValue];
211   [pipe writesFinishedWithError:nil];
213   [pipe startWithWriteable:writeable];
230   GRXBufferedPipe *pipe = [GRXBufferedPipe pipe];
231   pipe = nil;
234   pipe = [GRXBufferedPipe pipe];
236     [pipe writeValue:anyValue];
238   pipe = nil;
241   pipe = [GRXBufferedPipe pipe];
242   [pipe startWithWriteable:writeable];
243   pipe = nil;
246   pipe = [GRXBufferedPipe pipe];
248     [pipe writeValue:anyValue];
250   [pipe startWithWriteable:writeable];
251   pipe = nil;
254   pipe = [GRXBufferedPipe pipe];
255   [pipe startWithWriteable:writeable];
257     [pipe writeValue:anyValue];
259   pipe.state = GRXWriterStatePaused;
261     [pipe writeValue:anyValue];
263   pipe = nil;
266   pipe = [GRXBufferedPipe pipe];
267   [pipe startWithWriteable:writeable];
269     [pipe writeValue:anyValue];
271   pipe.state = GRXWriterStatePaused;
273     [pipe writeValue:anyValue];
275   [pipe finishWithError:nil];
276   pipe = nil;
279   pipe = [GRXBufferedPipe pipe];
280   [pipe startWithWriteable:writeable];
282     [pipe writeValue:anyValue];
284   pipe.state = GRXWriterStatePaused;
286     [pipe writeValue:anyValue];
288   [pipe finishWithError:nil];
289   pipe.state = GRXWriterStateStarted;
290   pipe = nil;