Scala:具有返回Future的参数或泛型类型参数的方法

Question

我的标题可能没有描述我试图理解的问题代码:

这是一段代码:

def getMeConcurrentInputStream[A, I <: InputStream](in:I)(fn:I => A):Future[A] = {
    future {
      fn(in)
    }andThen {
      case all => in.close()
    }
  }

我试图了解该功能的用途.这是什么:

[A, I <: InputStream](in:I)(fn:I => A)

这是什么: (in:I)(fn:I => A)

而功能正在回归未来？我怎么解释:Future[A]

我如何解释以上所有内容？如何通过从代码中的其他位置调用它来使用此函数？

Answer 1

def getMeConcurrentInputStream

功能命名 getMeConcurrentInputStream

[A, I <: InputStream]

与一般类型A和类型I是InputStream或它的一个子类.

(in:I)(fn:I => A)

具有参数列表I和接受I和返回的函数的参数列表A

:Future[A] = {

返回一个Future类型A

future {

这会Future在范围内隐式创建ExecutionContext

fn(in)

并且将来fn用参数调用函数in.

}andThen {

无论是成功还是失败,

case all =>

在所有情况下

in.close()

调用.close()上in.

此函数包含一些涉及InputStreama的操作,并在Future完成时关闭它.

例如,假设我想异步读取文件的第一个字节,然后将其打印出来.我能做到这一点:

val fileInputStream = new FileInputStream("example.txt")
val myFuture = getMeConcurrentInputStream(fileInputStream) { inputStream =>
    inputStream.read()
}
myFuture.map(println)

就个人而言,我看不出有多少用于此功能,但你去了.