lib/grumlin/transport.rb in grumlin-1.0.0.rc6 vs lib/grumlin/transport.rb in grumlin-1.0.0.rc7

@@ -68,19 +68,19 @@
   private
 
   def run_response_task
     with_guard do
       loop do
-        data = @connection.read
+        data = Oj.load(@connection.read.to_str, symbolize_names: true)
         @response_channel << data
       end
     end
   end
 
   def run_request_task
     with_guard do
       @request_channel.each do |message|
-        @connection.write(message)
+        @connection.write(Oj.dump(message, mode: :compat))
         @connection.flush
       end
     end
   end