Enabled disabled non-local returns in stdlib

This commit is contained in:
Michael Bogdanov
2014-10-22 12:41:45 +04:00
parent 11fd8fe392
commit 25d7c9f20a
11 changed files with 578 additions and 76 deletions
@@ -0,0 +1,178 @@
import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit
import java.util.concurrent.Executors
import java.util.concurrent.Callable
import java.util.concurrent.Future
val count: Int = 10;
var index: Int = 0;
val doneSignal = CountDownLatch(count)
val startSignal = CountDownLatch(1);
val mutex: Any = Object()
val results = arrayListOf<Int>()
val executorService = Executors.newFixedThreadPool(count)
class MyException(message: String): Exception(message)
enum class ExecutionType {
LOCAL
NON_LOCAL_SIMPLE
NON_LOCAL_EXCEPTION
NON_LOCAL_FINALLY
NON_LOCAL_EXCEPTION_AND_FINALLY
NON_LOCAL_EXCEPTION_AND_FINALLY_WITH_RETURN
NON_LOCAL_NESTED
}
class TestLocal(val name: String, val executionType: ExecutionType) : Callable<String> {
override fun call(): String {
startSignal.await()
return when (executionType) {
is ExecutionType.LOCAL -> local()
is ExecutionType.NON_LOCAL_SIMPLE -> nonLocalSimple()
is ExecutionType.NON_LOCAL_EXCEPTION -> nonLocalWithException()
is ExecutionType.NON_LOCAL_FINALLY -> nonLocalWithFinally()
is ExecutionType.NON_LOCAL_EXCEPTION_AND_FINALLY -> nonLocalWithExceptionAndFinally()
is ExecutionType.NON_LOCAL_EXCEPTION_AND_FINALLY_WITH_RETURN -> nonLocalWithExceptionAndFinallyWithReturn()
is ExecutionType.NON_LOCAL_NESTED -> nonLocalNested()
else -> "fail"
}
}
private fun underMutexFun() {
results.add(++index);
doneSignal.countDown()
}
fun local(): String {
synchronized(mutex) {
underMutexFun()
}
return executionType.toString()
}
fun nonLocalSimple(): String {
synchronized(mutex) {
underMutexFun()
return executionType.name()
}
return "fail"
}
fun nonLocalWithException(): String {
synchronized(mutex) {
try {
underMutexFun()
throw MyException(executionType.name())
} catch (e: MyException) {
return e.getMessage()!!
}
}
return "fail"
}
fun nonLocalWithFinally(): String {
synchronized(mutex) {
try {
underMutexFun()
return "fail"
} finally {
return executionType.name()
}
}
return "fail"
}
fun nonLocalWithExceptionAndFinally(): String {
synchronized(mutex) {
try {
underMutexFun()
throw MyException(executionType.name())
} catch (e: MyException) {
return e.getMessage()!!
} finally {
"123"
}
}
return "fail"
}
fun nonLocalWithExceptionAndFinallyWithReturn(): String {
synchronized(mutex) {
try {
underMutexFun()
throw MyException(executionType.name())
} catch (e: MyException) {
return "fail1"
} finally {
return executionType.name()
}
}
return "fail"
}
fun nonLocalNested(): String {
synchronized(mutex) {
try {
try {
underMutexFun()
throw MyException(executionType.name())
} catch (e: MyException) {
return "fail1"
} finally {
return executionType.name()
}
} finally {
val p = 1 + 1
}
}
return "fail"
}
}
fun testTemplate(type: ExecutionType, producer: (Int) -> Callable<String>): String {
try {
val futures = arrayListOf<Future<String>>()
for (i in 1..count) {
futures.add(executorService.submit (producer(i)))
}
startSignal.countDown()
val b = doneSignal.await(10, TimeUnit.SECONDS)
if (!b) return "fail: processes not finished"
for (i in 1..count) {
if (results[i - 1] != i)
return "fail $i != ${results[i]}: synchronization not works : " + results.joinToString()
}
for (f in futures) {
if (f.get() != type.name()) return "failed result ${f.get()} != ${type.name()}"
}
} finally {
}
return "OK"
}
fun runTest(type: ExecutionType): String {
return testTemplate (type) { TestLocal(it.toString(), type) }
}
fun box(): String {
try {
for (type in ExecutionType.values()) {
val result = runTest(type)
if (result != "OK") return "fail on $type execution: $result"
}
} finally {
executorService.shutdown()
}
return "OK"
}
@@ -0,0 +1,176 @@
import java.io.Closeable
import java.io.Closeable
import java.io.Closeable
class MyException(message: String) : Exception(message)
class Holder(var value: String) {
public fun plusAssign(s: String?) {
value += s
if (s != "closed") {
value += "->"
}
}
}
class TestLocal() : Closeable {
var status = Holder("")
private fun underMutexFun() {
status += "called"
}
fun local(): Holder {
use {
underMutexFun()
}
return status
}
fun nonLocalSimple(): Holder {
use {
underMutexFun()
return status
}
return Holder("fail")
}
fun nonLocalWithException(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()!!
return status
}
}
return Holder("fail")
}
fun nonLocalWithFinally(): Holder {
use {
try {
underMutexFun()
return Holder("fail")
} finally {
status += "finally"
return status
}
}
return Holder("fail")
}
fun nonLocalWithExceptionAndFinally(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()
return status
} finally {
status += "finally"
}
}
return Holder("fail")
}
fun nonLocalWithExceptionAndFinallyWithReturn(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()
return Holder("fail")
} finally {
status += "finally"
return status
}
}
return Holder("fail")
}
fun nonLocalNestedWithException(): Holder {
use {
try {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += "exception"
return Holder("fail")
} finally {
status += "finally1"
return status
}
} finally {
status += "finally2"
}
}
return Holder("fail")
}
fun nonLocalNestedFinally(): Holder {
use {
try {
try {
underMutexFun()
return status
} finally {
status += "finally1"
status
}
} finally {
status += "finally2"
}
}
return Holder("fail")
}
override fun close() {
status += "closed"
}
}
fun box(): String {
var callable = TestLocal()
var result = callable.local()
if (result.value != "called->closed") return "fail local: " + result.value
callable = TestLocal()
result = callable.nonLocalSimple()
if (result.value != "called->closed") return "fail nonLocalSimple: " + result.value
callable = TestLocal()
result = callable.nonLocalWithException()
if (result.value != "called->exception->closed") return "fail nonLocalWithException: " + result.value
callable = TestLocal()
result = callable.nonLocalWithFinally()
if (result.value != "called->finally->closed") return "fail nonLocalWithFinally: " + result.value
callable = TestLocal()
result = callable.nonLocalWithExceptionAndFinally()
if (result.value != "called->exception->finally->closed") return "fail nonLocalWithExceptionAndFinally: " + result.value
callable = TestLocal()
result = callable.nonLocalWithExceptionAndFinallyWithReturn()
if (result.value != "called->exception->finally->closed") return "fail nonLocalWithExceptionAndFinallyWithReturn: " + result.value
callable = TestLocal()
result = callable.nonLocalNestedWithException()
if (result.value != "called->exception->finally1->finally2->closed") return "fail nonLocalNestedWithException: " + result.value
callable = TestLocal()
result = callable.nonLocalNestedFinally()
if (result.value != "called->finally1->finally2->closed") return "fail nonLocalNestedFinally: " + result.value
return "OK"
}
@@ -0,0 +1,189 @@
import java.io.Closeable
import java.io.Closeable
import java.io.Closeable
import kotlin.test.assertTrue
import kotlin.test.fail
import kotlin.test.assertEquals
class MyException(message: String) : Exception(message)
class Holder(var value: String) {
public fun plusAssign(s: String?) {
value += s
if (s != "closed") {
value += "->"
}
}
}
class TestLocal() : Closeable {
var status = Holder("")
private fun underMutexFun() {
status += "called"
}
fun local(): Holder {
use {
underMutexFun()
}
return status
}
fun nonLocalSimple(): Holder {
use {
underMutexFun()
return status
}
return Holder("fail")
}
fun nonLocalWithException(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()!!
return status
}
}
return Holder("fail")
}
fun nonLocalWithFinally(): Holder {
use {
try {
underMutexFun()
return Holder("fail")
} finally {
status += "finally"
return status
}
}
return Holder("fail")
}
fun nonLocalWithExceptionAndFinally(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()
return status
} finally {
status += "finally"
}
}
return Holder("fail")
}
fun nonLocalWithExceptionAndFinallyWithReturn(): Holder {
use {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += e.getMessage()
return Holder("fail")
} finally {
status += "finally"
return status
}
}
return Holder("fail")
}
fun nonLocalNestedWithException(): Holder {
use {
try {
try {
underMutexFun()
throw MyException("exception")
} catch (e: MyException) {
status += "exception"
return Holder("fail")
} finally {
status += "finally1"
return status
}
} finally {
status += "finally2"
}
}
return Holder("fail")
}
fun nonLocalNestedFinally(): Holder {
use {
try {
try {
underMutexFun()
return status
} finally {
status += "finally1"
status
}
} finally {
status += "finally2"
}
}
return Holder("fail")
}
override fun close() {
status += "closed"
throw MyException("error")
}
}
fun box(): String {
assertError(1,"called->closed") {
local()
}
assertError(2, "called->closed") {
nonLocalSimple()
}
assertError(3, "called->exception->closed") {
nonLocalWithException()
}
assertError(4, "called->finally->closed") {
nonLocalWithFinally()
}
assertError(5, "called->exception->finally->closed") {
nonLocalWithExceptionAndFinally()
}
assertError(6, "called->exception->finally->closed") {
nonLocalWithExceptionAndFinallyWithReturn()
}
assertError(7, "called->exception->finally1->finally2->closed") {
nonLocalNestedWithException()
}
assertError(8, "called->finally1->finally2->closed") {
nonLocalNestedFinally()
}
return "OK"
}
public fun assertError(index: Int, expected: String, l: TestLocal.()->Unit) {
val testLocal = TestLocal()
try {
testLocal.l()
fail("fail $index: no error")
} catch (e: Exception) {
assertEquals(expected, testLocal.status.value, "failed on $index")
}
}
@@ -1,42 +0,0 @@
import java.io.Closeable
import java.util.concurrent.locks.Lock
import java.util.concurrent.locks.ReentrantReadWriteLock
import kotlin.concurrent.*
// Non-local returns for these functions are temporarily disabled because they contain try-finally blocks and
// the compiler doesn't correctly include the "finally" section into the inlined result.
// Once the compiler is fixed (KT-5506), non-local returns can be re-allowed for these functions
fun testSynchronized(): Int {
synchronized("") {
<!RETURN_NOT_ALLOWED!>return 1<!>
}
<!NO_RETURN_IN_FUNCTION_WITH_BLOCK_BODY!>}<!>
fun testUse(f: Closeable): Int {
f.use {
<!RETURN_NOT_ALLOWED!>return 2<!>
}
<!NO_RETURN_IN_FUNCTION_WITH_BLOCK_BODY!>}<!>
fun testWithLock(l: Lock): Int {
l.withLock {
<!RETURN_NOT_ALLOWED!>return 3<!>
}
<!NO_RETURN_IN_FUNCTION_WITH_BLOCK_BODY!>}<!>
fun testRead(l: ReentrantReadWriteLock): Int {
l.read {
<!RETURN_NOT_ALLOWED!>return 4<!>
}
<!NO_RETURN_IN_FUNCTION_WITH_BLOCK_BODY!>}<!>
fun testWrite(l: ReentrantReadWriteLock): Int {
l.write {
<!RETURN_NOT_ALLOWED!>return 5<!>
}
<!NO_RETURN_IN_FUNCTION_WITH_BLOCK_BODY!>}<!>
@@ -1,7 +0,0 @@
package
internal fun testRead(/*0*/ l: java.util.concurrent.locks.ReentrantReadWriteLock): kotlin.Int
internal fun testSynchronized(): kotlin.Int
internal fun testUse(/*0*/ f: java.io.Closeable): kotlin.Int
internal fun testWithLock(/*0*/ l: java.util.concurrent.locks.Lock): kotlin.Int
internal fun testWrite(/*0*/ l: java.util.concurrent.locks.ReentrantReadWriteLock): kotlin.Int
@@ -30,7 +30,7 @@ import java.util.regex.Pattern;
@SuppressWarnings("all")
@TestMetadata("compiler/testData/diagnostics/testsWithStdLib")
@TestDataPath("$PROJECT_ROOT")
@InnerTestClasses({JetDiagnosticsTestWithStdLibGenerated.Annotations.class, JetDiagnosticsTestWithStdLibGenerated.CallableReference.class, JetDiagnosticsTestWithStdLibGenerated.DuplicateJvmSignature.class, JetDiagnosticsTestWithStdLibGenerated.FunctionLiterals.class, JetDiagnosticsTestWithStdLibGenerated.KotlinSignature.class, JetDiagnosticsTestWithStdLibGenerated.NonLocalReturns.class})
@InnerTestClasses({JetDiagnosticsTestWithStdLibGenerated.Annotations.class, JetDiagnosticsTestWithStdLibGenerated.CallableReference.class, JetDiagnosticsTestWithStdLibGenerated.DuplicateJvmSignature.class, JetDiagnosticsTestWithStdLibGenerated.FunctionLiterals.class, JetDiagnosticsTestWithStdLibGenerated.KotlinSignature.class})
@RunWith(JUnit3RunnerWithInners.class)
public class JetDiagnosticsTestWithStdLibGenerated extends AbstractJetDiagnosticsTestWithStdLib {
public void testAllFilesPresentInTestsWithStdLib() throws Exception {
@@ -620,19 +620,4 @@ public class JetDiagnosticsTestWithStdLibGenerated extends AbstractJetDiagnostic
doTest(fileName);
}
}
@TestMetadata("compiler/testData/diagnostics/testsWithStdLib/nonLocalReturns")
@TestDataPath("$PROJECT_ROOT")
@RunWith(JUnit3RunnerWithInners.class)
public static class NonLocalReturns extends AbstractJetDiagnosticsTestWithStdLib {
public void testAllFilesPresentInNonLocalReturns() throws Exception {
JetTestUtils.assertAllTestsPresentByMetadata(this.getClass(), new File("compiler/testData/diagnostics/testsWithStdLib/nonLocalReturns"), Pattern.compile("^(.+)\\.kt$"), true);
}
@TestMetadata("prohibitNonLocalReturnOutOfTryCatchFinally.kt")
public void testProhibitNonLocalReturnOutOfTryCatchFinally() throws Exception {
String fileName = JetTestUtils.navigationMetadata("compiler/testData/diagnostics/testsWithStdLib/nonLocalReturns/prohibitNonLocalReturnOutOfTryCatchFinally.kt");
doTest(fileName);
}
}
}
@@ -30,7 +30,7 @@ import java.util.regex.Pattern;
@SuppressWarnings("all")
@TestMetadata("compiler/testData/codegen/boxWithStdlib")
@TestDataPath("$PROJECT_ROOT")
@InnerTestClasses({BlackBoxWithStdlibCodegenTestGenerated.Annotations.class, BlackBoxWithStdlibCodegenTestGenerated.Arrays.class, BlackBoxWithStdlibCodegenTestGenerated.BoxingOptimization.class, BlackBoxWithStdlibCodegenTestGenerated.CallableReference.class, BlackBoxWithStdlibCodegenTestGenerated.Casts.class, BlackBoxWithStdlibCodegenTestGenerated.DataClasses.class, BlackBoxWithStdlibCodegenTestGenerated.DefaultArguments.class, BlackBoxWithStdlibCodegenTestGenerated.Enum.class, BlackBoxWithStdlibCodegenTestGenerated.Evaluate.class, BlackBoxWithStdlibCodegenTestGenerated.FullJdk.class, BlackBoxWithStdlibCodegenTestGenerated.HashPMap.class, BlackBoxWithStdlibCodegenTestGenerated.Intrinsics.class, BlackBoxWithStdlibCodegenTestGenerated.JdkAnnotations.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformNames.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformStatic.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformTypes.class, BlackBoxWithStdlibCodegenTestGenerated.Ranges.class, BlackBoxWithStdlibCodegenTestGenerated.Reflection.class, BlackBoxWithStdlibCodegenTestGenerated.Regressions.class, BlackBoxWithStdlibCodegenTestGenerated.StoreStackBeforeInline.class, BlackBoxWithStdlibCodegenTestGenerated.Strings.class, BlackBoxWithStdlibCodegenTestGenerated.ToArray.class, BlackBoxWithStdlibCodegenTestGenerated.Vararg.class, BlackBoxWithStdlibCodegenTestGenerated.When.class, BlackBoxWithStdlibCodegenTestGenerated.WhenEnumOptimization.class, BlackBoxWithStdlibCodegenTestGenerated.WhenStringOptimization.class})
@InnerTestClasses({BlackBoxWithStdlibCodegenTestGenerated.Annotations.class, BlackBoxWithStdlibCodegenTestGenerated.Arrays.class, BlackBoxWithStdlibCodegenTestGenerated.BoxingOptimization.class, BlackBoxWithStdlibCodegenTestGenerated.CallableReference.class, BlackBoxWithStdlibCodegenTestGenerated.Casts.class, BlackBoxWithStdlibCodegenTestGenerated.DataClasses.class, BlackBoxWithStdlibCodegenTestGenerated.DefaultArguments.class, BlackBoxWithStdlibCodegenTestGenerated.Enum.class, BlackBoxWithStdlibCodegenTestGenerated.Evaluate.class, BlackBoxWithStdlibCodegenTestGenerated.FullJdk.class, BlackBoxWithStdlibCodegenTestGenerated.HashPMap.class, BlackBoxWithStdlibCodegenTestGenerated.Intrinsics.class, BlackBoxWithStdlibCodegenTestGenerated.JdkAnnotations.class, BlackBoxWithStdlibCodegenTestGenerated.NonLocalReturns.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformNames.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformStatic.class, BlackBoxWithStdlibCodegenTestGenerated.PlatformTypes.class, BlackBoxWithStdlibCodegenTestGenerated.Ranges.class, BlackBoxWithStdlibCodegenTestGenerated.Reflection.class, BlackBoxWithStdlibCodegenTestGenerated.Regressions.class, BlackBoxWithStdlibCodegenTestGenerated.StoreStackBeforeInline.class, BlackBoxWithStdlibCodegenTestGenerated.Strings.class, BlackBoxWithStdlibCodegenTestGenerated.ToArray.class, BlackBoxWithStdlibCodegenTestGenerated.Vararg.class, BlackBoxWithStdlibCodegenTestGenerated.When.class, BlackBoxWithStdlibCodegenTestGenerated.WhenEnumOptimization.class, BlackBoxWithStdlibCodegenTestGenerated.WhenStringOptimization.class})
@RunWith(JUnit3RunnerWithInners.class)
public class BlackBoxWithStdlibCodegenTestGenerated extends AbstractBlackBoxCodegenTest {
public void testAllFilesPresentInBoxWithStdlib() throws Exception {
@@ -1452,6 +1452,33 @@ public class BlackBoxWithStdlibCodegenTestGenerated extends AbstractBlackBoxCode
}
}
@TestMetadata("compiler/testData/codegen/boxWithStdlib/nonLocalReturns")
@TestDataPath("$PROJECT_ROOT")
@RunWith(JUnit3RunnerWithInners.class)
public static class NonLocalReturns extends AbstractBlackBoxCodegenTest {
public void testAllFilesPresentInNonLocalReturns() throws Exception {
JetTestUtils.assertAllTestsPresentByMetadata(this.getClass(), new File("compiler/testData/codegen/boxWithStdlib/nonLocalReturns"), Pattern.compile("^(.+)\\.kt$"), true);
}
@TestMetadata("synchronized.kt")
public void testSynchronized() throws Exception {
String fileName = JetTestUtils.navigationMetadata("compiler/testData/codegen/boxWithStdlib/nonLocalReturns/synchronized.kt");
doTestWithStdlib(fileName);
}
@TestMetadata("use.kt")
public void testUse() throws Exception {
String fileName = JetTestUtils.navigationMetadata("compiler/testData/codegen/boxWithStdlib/nonLocalReturns/use.kt");
doTestWithStdlib(fileName);
}
@TestMetadata("useWithException.kt")
public void testUseWithException() throws Exception {
String fileName = JetTestUtils.navigationMetadata("compiler/testData/codegen/boxWithStdlib/nonLocalReturns/useWithException.kt");
doTestWithStdlib(fileName);
}
}
@TestMetadata("compiler/testData/codegen/boxWithStdlib/platformNames")
@TestDataPath("$PROJECT_ROOT")
@RunWith(JUnit3RunnerWithInners.class)
+1 -2
View File
@@ -4,7 +4,6 @@ import java.lang.annotation.Retention
import java.lang.annotation.RetentionPolicy
import kotlin.jvm.internal.unsafe.*
import kotlin.jvm.internal.Intrinsic
import kotlin.InlineOption.ONLY_LOCAL_RETURN
/**
* This annotation indicates what exceptions should be declared by a function when compiled to a JVM method
@@ -26,7 +25,7 @@ public annotation class throws(public vararg val exceptionClasses: Class<out Thr
[Intrinsic("kotlin.javaClass.function")] public fun <reified T: Any> javaClass(): Class<T> = null as Class<T>
public inline fun <R> synchronized(lock: Any, [inlineOptions(ONLY_LOCAL_RETURN)] block: () -> R): R {
public inline fun <R> synchronized(lock: Any, block: () -> R): R {
monitorEnter(lock)
try {
return block()
@@ -3,13 +3,12 @@ package kotlin.concurrent
import java.util.concurrent.locks.Lock
import java.util.concurrent.locks.ReentrantReadWriteLock
import java.util.concurrent.CountDownLatch
import kotlin.InlineOption.ONLY_LOCAL_RETURN
/**
* Executes given calculation under lock
* Returns result of the calculation
*/
public inline fun <T> Lock.withLock([inlineOptions(ONLY_LOCAL_RETURN)] action: () -> T): T {
public inline fun <T> Lock.withLock(action: () -> T): T {
lock()
try {
return action()
@@ -22,7 +21,7 @@ public inline fun <T> Lock.withLock([inlineOptions(ONLY_LOCAL_RETURN)] action: (
* Executes given calculation under read lock
* Returns result of the calculation
*/
public inline fun <T> ReentrantReadWriteLock.read([inlineOptions(ONLY_LOCAL_RETURN)] action: () -> T): T {
public inline fun <T> ReentrantReadWriteLock.read(action: () -> T): T {
val rl = readLock()
rl.lock()
try {
@@ -38,7 +37,7 @@ public inline fun <T> ReentrantReadWriteLock.read([inlineOptions(ONLY_LOCAL_RETU
* If such write has been initiated by checking some condition, the condition must be rechecked inside the action to avoid possible races
* Returns result of the calculation
*/
public inline fun <T> ReentrantReadWriteLock.write([inlineOptions(ONLY_LOCAL_RETURN)] action: () -> T): T {
public inline fun <T> ReentrantReadWriteLock.write(action: () -> T): T {
val rl = readLock()
val readCount = if (getWriteHoldCount() == 0) getReadHoldCount() else 0
+1 -2
View File
@@ -1,10 +1,9 @@
package kotlin
import java.io.Closeable
import kotlin.InlineOption.ONLY_LOCAL_RETURN
/** Uses the given resource then closes it down correctly whether an exception is thrown or not */
public inline fun <T : Closeable, R> T.use([inlineOptions(ONLY_LOCAL_RETURN)] block: (T) -> R): R {
public inline fun <T : Closeable, R> T.use(block: (T) -> R): R {
var closed = false
try {
return block(this)
+1 -2
View File
@@ -4,7 +4,6 @@ import java.io.*
import java.nio.charset.*
import java.util.NoSuchElementException
import java.net.URL
import kotlin.InlineOption.ONLY_LOCAL_RETURN
/**
* Returns the default buffer size when working with buffered streams
@@ -193,7 +192,7 @@ public fun Writer.buffered(bufferSize: Int = defaultBufferSize): BufferedWriter
*/
public fun Reader.forEachLine(block: (String) -> Unit): Unit = useLines { lines -> lines.forEach(block) }
public inline fun <T> Reader.useLines([inlineOptions(ONLY_LOCAL_RETURN)] block: (Stream<String>) -> T): T =
public inline fun <T> Reader.useLines(block: (Stream<String>) -> T): T =
this.buffered().use { block(it.lines()) }
/**