Searched defs:pipeSink (Results 1 – 1 of 1) sorted by relevance
59 val pipeSink = pipe.sink.buffer() in fold() constant91 val pipeSink = pipe.sink.buffer() in foldWritesPipeContentsToSink() constant543 val pipeSink = pipe.sink.buffer() in sinkWriteThrowsIOExceptionUnblockBlockedWriter() constant555 val pipeSink = pipe.sink.buffer() in foldHoldsNoLocksWhenForwardingWrites() constant572 val pipeSink = pipe.sink.buffer() in foldFlushesWhenThereIsFoldedData() constant601 val pipeSink = pipe.sink.buffer() in foldingClosesUnderlyingSinkWhenPipeSinkIsClose() constant623 val pipeSink = pipe.sink.buffer() in cancelPreventsSinkWrite() constant662 val pipeSink = pipe.sink.buffer() in cancelInterruptsSinkWrite() constant744 val pipeSink = pipe.sink.buffer() in cancelInterruptsSinkFold() constant