lib/ruby_fs/stream.rb in ruby_fs-1.1.0 vs lib/ruby_fs/stream.rb in ruby_fs-1.1.1

@@ -1,5 +1,7 @@
+# encoding: utf-8
+
 require 'json'
 
 require 'ruby_fs/lexer'
 
 module RubyFS
@@ -37,10 +39,10 @@
       @socket = TCPSocket.from_ruby_socket ::TCPSocket.new(@host, @port)
       post_init
       loop { receive_data @socket.readpartial(4096) }
     rescue EOFError, IOError, Errno::ECONNREFUSED => e
       logger.info "Client socket closed due to (#{e.class}) #{e.message}!"
-      terminate
+      async.terminate
     end
 
     #
     # Send raw string data to the FS server
     #