debugging

websocket_client.rb

#!/usr/bin/env ruby

require 'celluloid/io'
require 'json'
require 'websocket'

class WebsocketClient
  include Celluloid::IO

  def initialize(host, port)
    puts "*** Connecting to echo server on #{host}:#{port}"

    @socket = TCPSocket.new(host, port)

    @handshake = WebSocket::Handshake::Client.new(:url => "ws://#{host}:#{port}")
    @socket.write @handshake.to_s

    payload = ->(num){ ['test', {name: 'Captain Test', number: num}].to_json }

    100_000.times {|i|
      frame = WebSocket::Frame::Outgoing::Server.new(:version => @handshake.version, :data => payload.call(i), :type => :text)
      @socket.write frame.to_s
    }
  end
end

client = WebsocketClient.new("127.0.0.1", 1234)