TCPSocket closing connection on spawn

connection_manager.cr

require "socket"

class ConnectionManager
  @client : TCPSocket
  @channel_send : Channel(String)
  @channel_receive : Channel(String)
  def initialize(server, port)
    @client = TCPSocket.new(server, port)
    @channel_send = Channel(String).new
    @channel_receive = Channel(String).new
  end
  
  def handle_send
    puts "Before handle_send spawn: @client.closed? : #{@client.closed?}"
    spawn do
      until @client.closed?
        puts "Waiting for messages..."
        msg = @channel_send.receive
        @client.write(msg.to_slice)
        puts "Sent message"
      end
    end
  rescue IO::EOFError
    puts "Server disconnected"
  ensure
    puts "handle_send closing client"
    @client.close
  end
  
  def handle_receive
    puts "Before handle_receive spawn: @client.closed? : #{@client.closed?}"
    spawn do
      until @client.closed?
        message = @client.gets || ""
        @channel_receive.send(message)
      end
    end
  rescue IO::EOFError 
    puts "Server disconnected"
  ensure
    puts "handle_receive closing client"
    @client.close
  end
  
  def start
    handle_receive()
    handle_send()
  end
  
  def send(msg)
    @channel_send.send(msg)
  end
  
  def receive
    @channel_receive.receive
  end
  
end


cm = ConnectionManager.new("localhost", 9000)
cm.start
cm.send("Initial connection\n")

sleep