gistfile1.txt

      it "should process close on message correctly " do
        EventMachine.run {
          MSG = "hello bi-directional data exchange"

          EventMachine::WebSocket.start(:host => "0.0.0.0", :port => 8085, :debug => true) do |ws|
            ws.onopen { p [:OPENED_WS, ws]}
            ws.onmessage {|msg| ws.close_webscoket }
            ws.onerror {|e| p [:WS_ERROR, e]}
            ws.onclose { p [:WS_CLOSE, ws]}
          end

          http = EventMachine::WebsocketRequest.new('ws://127.0.0.1:8085/').get :keepalive => true
          http.errback { failed(http) }
          http.callback {
            http.response_header.status.should == 101
            http.response_header['CONNECTION'].should match(/Upgrade/)
            http.response_header['UPGRADE'].should match(/websocket/)

            # push should only be invoked after handshake is complete
            http.send(MSG)
          }

          http.stream { |chunk|
            chunk.should == MSG
            EventMachine.stop
          }
        }
      end