Мы можем скопировать входной поток в выходной поток обычным и безопасным для типов способом, используя классы типов. Класс типов - это концепция. Это один из подходов к полиморфизму. В частности, это параметрический полиморфизм, потому что полиморфное поведение кодируется с использованием параметров. В нашем случае наши параметры будут универсальными типами для свойств Scala.
Создадим черты Reader[I]
и Writer[O]
, где I
и O
- это типы входного и выходного потоков соответственно.
trait Reader[I] {
def read(input: I, buffer: Array[Byte]): Int
}
trait Writer[O] {
def write(output: O, buffer: Array[Byte], startAt: Int, nBytesToWrite: Int): Unit
}
Теперь мы можем создать общий метод копирования, который может работать с вещами, которые подписываются на эти интерфейсы.
object CopyStreams {
type Bytes = Int
def apply[I, O](input: I, output: O, chunkSize: Bytes = 1024)(implicit r: Reader[I], w: Writer[O]): Unit = {
val buffer = Array.ofDim[Byte](chunkSize)
var count = -1
while ({count = r.read(input, buffer); count > 0})
w.write(output, buffer, 0, count)
}
}
Обратите внимание на неявные параметры r
и w
. По сути, мы говорим, что CopyStreams[I,O].apply
будет работать, если в области видимости есть значения Reader[I]
и Writer[O]
. Это позволит нам беспрепятственно вызывать CopyStreams (ввод, вывод).
Однако важно отметить, что эта реализация является общей. Он работает с типами, которые не зависят от фактических реализаций потоков.
В моем конкретном случае использования мне нужно было скопировать объекты S3 в локальные файлы. Итак, я сделал следующие неявные значения.
object Reader {
implicit val s3ObjectISReader = new Reader[S3ObjectInputStream] {
@inline override def read(input: S3ObjectInputStream, buffer: Array[Byte]): Int =
input.read(buffer)
}
}
object Writer {
implicit val fileOSWriter = new Writer[FileOutputStream] {
@inline override def write(output: FileOutputStream,
buffer: Array[Byte],
startAt: Int,
nBytesToWrite: Int): Unit =
output.write(buffer, startAt, nBytesToWrite)
}
}
Итак, теперь я могу сделать следующее:
val input:S3ObjectStream = ...
val output = new FileOutputStream(new File(...))
import Reader._
import Writer._
CopyStreams(input, output)
// close and such...
И если нам когда-нибудь понадобится скопировать разные типы потоков, нам нужно только написать новое Reader
или Writer
неявное значение. Мы можем использовать CopyStreams
код, не меняя его!
person
Malcolm
schedule
13.04.2015
BufferedInputStream
. - person Maurício Linhares   schedule 26.10.2012