Fixed concurrency specs.

Author: dblock

spec/slack/real_time/concurrency/celluloid_spec.rb

@@ -78,12 +78,17 @@ def read
 
           describe '#disconnect!' do
             it 'closes and nils the websocket' do
+              expect(ws).to receive(:emit)
               expect(ws).to receive(:close)
               socket.disconnect!
             end
           end
 
           context 'consumes data' do
+            let(:tcp_socket) { double(::Celluloid::IO::SSLSocket, connect: true) }
+            before do
+              allow_any_instance_of(described_class).to receive(:build_socket).and_return(tcp_socket)
+            end
             it 'runs' do
               expect(ws).to receive(:emit)
               expect(ws).to receive(:start)

spec/slack/real_time/concurrency/eventmachine_spec.rb

@@ -27,6 +27,7 @@
       describe '#disconnect!' do
         it 'closes and nils the websocket' do
           socket.instance_variable_set('@driver', ws)
+          expect(ws).to receive(:emit).with(:close)
           expect(ws).to receive(:close)
           socket.disconnect!
         end