lib/slack/real_time/concurrency/celluloid.rb in slack-ruby-client-0.6.0 vs lib/slack/real_time/concurrency/celluloid.rb in slack-ruby-client-0.7.0

- old
+ new

@@ -39,10 +39,16 @@ # connection closed end def read buffer = socket.readpartial(BLOCK_SIZE) + logger.debug("#{self.class}##{__method__}") { buffer } driver.parse buffer + end + + def write(data) + logger.debug("#{self.class}##{__method__}") { data } + socket.write(data) end def start_async future = yield self if block_given?