NSStreamEventHasBytesAvailableを呼び出すことができません

Python（Twisted）でサーバーを作成しました。サーバーに接続してサーバーにデータを送信しましたが、サーバーからデータを取得できず、NSStreamEventHasBytesAvailableが呼び出されません。

これが私がサーバーに接続する方法です：

CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)@"localhost", 3000, &readStream, &writeStream);
inputStream = (NSInputStream *)readStream;
outputStream = (NSOutputStream *)writeStream;
[inputStream setDelegate:self];
[outputStream setDelegate:self];
[inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[inputStream open];
[outputStream open];

ここに問題があります：

-(void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent
{
     NSString *event;
     switch (streamEvent)
     {
         case NSStreamEventHasBytesAvailable:
         event = @"NSStreamEventHasBytesAvailable";
         if (theStream == inputStream)
         {
             uint8_t buffer[1024];
             int len;
             while ([inputStream hasBytesAvailable])
             {
                NSLog(@"input =====%@",inputStream);

                len = [inputStream read:buffer maxLength:1024];
                NSLog(@"len -=======%d",len);
                if (len > 0)
                {
                    NSMutableString *output = [[NSMutableString alloc] initWithBytes:buffer length:len encoding:NSUTF8StringEncoding];
                    NSLog(@"Received data--------------------%@", output);
                }
             }
        }
        break;
    }
}

これはサーバー側のコードです。

from twisted.internet.protocol import Factory, Protocol
from twisted.internet import reactor

class IphoneChat(Protocol):
    def connectionMade(self):
        self.factory.clients.append(self)
        print "clients are ", self.factory.clients

    def connectionLost(self, reason):
        self.factory.clients.remove(self)

    def dataReceived(self, data):
        a = data.split(':')
        print a
        if len(a) > 1:
           command = a[0]
           content = a[1]

           msg = ""
           if command == "msg":
               msg = content
               print msg

    def message(self, message):
        self.transport.write(message + '\n')

        for c in self.factory.clients:
            c.message(msg)

factory = Factory()
factory.protocol = IphoneChat
factory.clients = []
reactor.listenTCP(650, factory)
print "Iphone Chat server started"
reactor.run()

私はたくさん試し、グーグルで検索しましたが、解決策が見つかりませんでした。それは私の時間を殺しているので、誰かがそれに取り組んだことがあれば、私を導き、サンプルコードを投稿してください。前もって感謝します。