Searched refs:pipeSink (Results 1 – 1 of 1) sorted by relevance
59 val pipeSink = pipe.sink.buffer() in fold() constant60 pipeSink.writeUtf8("hello") in fold()61 pipeSink.emit() in fold()76 pipeSink.writeUtf8("world") in fold()77 pipeSink.emit() in fold()84 pipeSink.close() in fold()91 val pipeSink = pipe.sink.buffer() in foldWritesPipeContentsToSink() constant92 pipeSink.writeUtf8("hello") in foldWritesPipeContentsToSink()93 pipeSink.emit() in foldWritesPipeContentsToSink()543 val pipeSink = pipe.sink.buffer() in sinkWriteThrowsIOExceptionUnblockBlockedWriter() constant[all …]