def METHOD_NAME(self):
    read = Mock()
    ss = TcpipSocketStream(None, read, 10.0, None)
    ss.connect()
    self.assertTrue(ss.connected)
    ss.disconnect()
    self.assertFalse(ss.connected)
    read.close.assert_called_once()