luciano/babashka
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Send bencode using BufferedOutputStream (#342)

Browse source 
This new implementation is faster because you only flush when you issue `.flush`, or until the buffer is full. Some simple experiments with Chlorine confirmed that small messages are being received in a whole block, instead of fragmented.
This commit is contained in:
Maurício Szabo 2020-04-11 04:47:06 -03:00 committed by GitHub
parent 1c467080fa
commit 9f199ddef7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/babashka/impl/nrepl_server.clj
View file

@ -7,7 +7,7 @@
[sci.impl.interpreter :refer [eval-string*]] [sci.impl.interpreter :refer [eval-string*]]
[sci.impl.utils :as sci-utils] [sci.impl.utils :as sci-utils]
[sci.impl.vars :as vars]) [sci.impl.vars :as vars])
(:import [java.io StringWriter OutputStream InputStream PushbackInputStream EOFException] (:import [java.io StringWriter OutputStream InputStream PushbackInputStream EOFException BufferedOutputStream]
[java.net ServerSocket])) [java.net ServerSocket]))
(set! *warn-on-reflection* true) (set! *warn-on-reflection* true)
@ -166,7 +166,8 @@
(let [client-socket (.accept listener) (let [client-socket (.accept listener)
in (.getInputStream client-socket) in (.getInputStream client-socket)
in (PushbackInputStream. in) in (PushbackInputStream. in)
out (.getOutputStream client-socket)] out (.getOutputStream client-socket)
out (BufferedOutputStream. out)]
(when @dev? (println "Connected.")) (when @dev? (println "Connected."))
(sci/future (sci/future
(sci/binding (sci/binding