Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- object ConnectedStreamsApp extends App {
- def writer(outputStream: OutputStream): Unit = {
- val writer = new PrintStream(outputStream)
- (1 to 1000).foreach { i =>
- writer.println(s"line $i")
- Thread.sleep(50)
- }
- writer.close()
- }
- def reader(inputStream: InputStream): Unit = {
- val reader = new BufferedReader(new InputStreamReader(inputStream))
- while (true) {
- var line = reader.readLine()
- if (line == null) {
- reader.close()
- return
- }
- println(s"read: $line")
- }
- }
- val in = new PipedInputStream(4024)
- val out = new PipedOutputStream(in)
- val writerThread = new Thread(() => writer(out))
- writerThread.start()
- reader(in)
- writerThread.join()
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement