Stream-Kontinuierlich liest nur für 1 Minute

Question

Stream.continually kehrt leer String wenn in.readLine länger dauert als 1 minute

val f = SSLSocketFactory.getDefault.asInstanceOf[SSLSocketFactory] 
val s = f.createSocket(ip, port).asInstanceOf[SSLSocket] 
s.startHandshake() 
s.setTcpNoDelay(true) 
val out = new BufferedWriter(new OutputStreamWriter(s.getOutputStream)) 
val in = new BufferedReader(new InputStreamReader(s.getInputStream)) 

val in = new BufferedReader(new InputStreamReader(s.getInputStream))  
Stream.continually(in.readLine()).takeWhile(_ != null).mkString 

Warum geschieht das?

Kann ich dies mit einer Eigenschaft ändern.

Ich habe die gesamte Stream-Dokumentation durchgesehen, aber ich denke, dass mir etwas fehlen könnte.

Ich habe auch versucht, das Hinzufügen s.setSoTimeout(300000) Auch las ich die offizielle Dokumentation für SSLSocketFactory aber keinen Standard TimeOut finden kann. Auch fand nicht für SSLSocket

---

FAZIT (nach diesen Fehler debuggen)

Das hat nichts mit Strom zu tun. Es hat auch nichts mit SSLSocketFactory oder SSLSocket zu tun. Es war ein Timeout-Problem im Proxy. Ich habe alles falsch verstanden.

Answer 1

Dies steht in keinem Zusammenhang mit Stream. Versuchen Sie Stream aus Ihrem Code unter:

val ip = "74.125.141.147" // google 
val port = 443 

val f = SSLSocketFactory.getDefault.asInstanceOf[SSLSocketFactory] 
val s = f.createSocket(ip, port).asInstanceOf[SSLSocket] 
s.startHandshake() 
s.setTcpNoDelay(true) 

val out = new BufferedWriter(new OutputStreamWriter(s.getOutputStream)) 
val in = new BufferedReader(new InputStreamReader(s.getInputStream)) 

println { 
    in.readLine() 
} 

Dies führte schließlich null druckt, wie es sein sollte (ich glaube, wenn die Fernbedienung langweilig wird und auflegt).

Was passiert ist, dass , mit einer leeren Sequenz, wird eine leere Zeichenfolge erzeugen.