Searched refs:pipeSource (Results 1 – 1 of 1) sorted by relevance
63 val pipeSource = pipe.source.buffer() in fold() constant64 assertEquals("hello", pipeSource.readUtf8(5)) in fold()81 pipeSource.readUtf8() in fold()679 val pipeSource = pipe.source.buffer() in cancelPreventsSourceRead() constant682 pipeSource.require(1) in cancelPreventsSourceRead()705 val pipeSource = pipe.source.buffer() in cancelInterruptsSourceRead() constant709 pipeSource.require(1) in cancelInterruptsSourceRead()