diff --git a/BitTorrent/Peer/Communicator/TorrentPeerCommunicator.swift b/BitTorrent/Peer/Communicator/TorrentPeerCommunicator.swift
index ba797ec..50980f4 100644
--- a/BitTorrent/Peer/Communicator/TorrentPeerCommunicator.swift
+++ b/BitTorrent/Peer/Communicator/TorrentPeerCommunicator.swift
@@ -225,6 +225,7 @@ extension TorrentPeerCommunicator: TCPConnectionDelegate {
     
     func tcpConnection(_ sender: TCPConnectionProtocol, didConnectToHost host: String, port: UInt16) {
         delegate?.peerConnected(self)
+        connection.readData(withTimeout: -1, tag: 0)
     }
     
     func tcpConnection(_ sender: TCPConnectionProtocol, didRead data: Data, withTag tag: Int) {