RE: NSXMLParser and initWithStream
RE: NSXMLParser and initWithStream
- Subject: RE: NSXMLParser and initWithStream
- From: John Drake <email@hidden>
- Date: Thu, 31 May 2012 02:14:13 -0400
- Importance: Normal
I figured out what the problem was and answering it here incase anyone else runs into this problem in the future since +[NSXMLParser initWithStream] doesn't have a lot lot of documentation out there.
I needed to call -[NSXMLParser parse] right after I allocate NSXMLParser and set myself as delegate. But because it's a synchronous function, I need to call it another thread so I don't block the current thread and it can receive the NSStream events. I also don't need to make myself the delegate for NSInputStream.
This can be done pretty simply using Grand Central Dispatch (GCD) like so:
// alloc and init the xml parserxmlParser = [[NSXMLParser alloc] initWithStream:inputStream];[xmlParser setDelegate:self];
// block to executedispatch_block_t dispatch_block = ^(void){ [xmlParser parse];};
// create a queue with a unique namedispatch_queue_t dispatch_queue = dispatch_queue_create("parser.queue", NULL);
// dispatch queuedispatch_async(dispatch_queue, dispatch_block);
// cleanupdispatch_release(dispatch_queue);
And here is the complete working example, just incase anyone wasn't able to follow what I posted above.
ContentParser.h
@interface ContentParser : NSObject <NSStreamDelegate, NSXMLParserDelegate>{ NSInputStream *inputStream; NSOutputStream *outputStream; NSMutableData *receivedData; NSXMLParser *xmlParser;}- (void)initStream;ContentParser.m
@implementation ContentParser
- (void)initStream{ CFReadStreamRef readStream; CFWriteStreamRef writeStream;
CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault, (CFStringRef)@"<hostname>", <port>, &readStream, &writeStream);
inputStream = (__bridge NSInputStream *)readStream; outputStream = (__bridge NSOutputStream *)writeStream;
outputStream.delegate = self;
[inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[inputStream open]; [outputStream open];
xmlParser = [[NSXMLParser alloc] initWithStream:inputStream]; [xmlParser setDelegate:self];
dispatch_block_t dispatch_block = ^(void) { [xmlParser parse]; };
dispatch_queue_t dispatch_queue = dispatch_queue_create("parser.queue", NULL); dispatch_async(dispatch_queue, dispatch_block); dispatch_release(dispatch_queue);}
- (void)parser:(NSXMLParser *)parser didStartElement:(NSString *)elementName namespaceURI:(NSString *)namespaceURI qualifiedName:(NSString *)qName attributes:(NSDictionary *)attributeDict{ NSLog(@"didStartElement: %@, attributeDict: %@", elementName, attributeDict);}
- (void)parser:(NSXMLParser *)parser foundCharacters:(NSString *)string{ NSLog(@"foundCharacters: %@", string);}
- (void)parser:(NSXMLParser *)parser didEndElement:(NSString *)elementName namespaceURI:(NSString *)namespaceURI qualifiedName:(NSString *)qName{ NSLog(@"didEndElement: %@", elementName);}
- (void)parser:(NSXMLParser *)parser parseErrorOccurred:(NSError *)parseError{ NSLog(@"Error %ld, Description: %@, Line: %ld, Column: %ld", [parseError code], [[parser parserError] localizedDescription], [parser lineNumber], [parser columnNumber]);}
- (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode{ switch (eventCode) { case NSStreamEventHasSpaceAvailable: { /* write bytes to socket */ break; } default: break; }}
@end
----------------------------------------
> From: email@hidden
> Subject: NSXMLParser and initWithStream
> Date: Sun, 27 May 2012 20:14:16 -0400
> To: email@hidden
>
> I'm trying to use the NSStream classes to parse incoming incremental XML data. The data is never a complete XML Document, but I want to receive and process it in incremental chunks based off how much ever the socket can read.
>
> Looking at the documentation for NSXMLParser, it seems like the initWithStream: method to initialize a NSXMLParser would be the perfect solution to my problem. I can initialize the parser with a NSInputStream and then call the parse method on NSXMLParser whenever I receive data over my socket which should in turn call the NSXMLParser delegates.
>
> However, I'm not seeing any of the delegates being called, the only method I see being called is the stream delegate stream:handleEvent:. There seems to be little to no examples of this API from Apple or other developers. I could use libxml2 directly to accomplish what I want, but I am hoping I am just using NSXMLParser incorrectly.
>
> Here is the source for what I am trying:
>
> ContentParser.h:
>
> @interface ContentParser : NSObject <NSStreamDelegate,
> NSXMLParserDelegate>
> {
> NSInputStream *inputStream;
> NSOutputStream *outputStream;
> NSMutableData *receivedData;
> NSXMLParser *xmlParser;
> }
> - (void)initStream;
>
> ContentParser.m:
>
> @implementation ContentParser
>
> - (void)initStream
> {
> CFReadStreamRef readStream;
> CFWriteStreamRef writeStream;
>
> CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault,
> (CFStringRef)@"<hostname>",
> <port>,
> &readStream,
> &writeStream);
>
> inputStream = (__bridge NSInputStream *)readStream;
> outputStream = (__bridge NSOutputStream *)writeStream;
>
> inputStream.delegate = self;
> outputStream.delegate = self;
>
> [inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop]
> forMode:NSDefaultRunLoopMode];
> [outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop]
> forMode:NSDefaultRunLoopMode];
>
> [inputStream open];
> [outputStream open];
>
> xmlParser = [[NSXMLParser alloc] initWithStream:inputStream];
> [xmlParser setDelegate:self];
> }
>
> - (void)parser:(NSXMLParser *)parser didStartElement:(NSString *)elementName
> namespaceURI:(NSString *)namespaceURI
> qualifiedName:(NSString *)qName
> attributes:(NSDictionary *)attributeDict
> {
> NSLog(@"didStartElement: %@, attributeDict: %@", elementName, attributeDict);
> }
>
> - (void)parser:(NSXMLParser *)parser foundCharacters:(NSString *)string
> {
> NSLog(@"foundCharacters: %@", string);
> }
>
> - (void)parser:(NSXMLParser *)parser didEndElement:(NSString *)elementName
> namespaceURI:(NSString *)namespaceURI
> qualifiedName:(NSString *)qName
> {
> NSLog(@"didEndElement: %@", elementName);
> }
>
> - (void)parser:(NSXMLParser *)parser parseErrorOccurred:(NSError *)parseError
> {
> NSLog(@"Error %ld, Description: %@, Line: %ld, Column: %ld",
> [parseError code], [[parser parserError] localizedDescription],
> [parser lineNumber], [parser columnNumber]);
> }
>
>
> - (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode
> {
> switch (eventCode) {
> case NSStreamEventHasBytesAvailable:
> {
> if (stream == inputStream) {
> NSInputStream *is = (NSInputStream *)stream;
> if (receivedData == nil) {
> receivedData = [[NSMutableData alloc] init];
> }
>
> uint8_t buf[1024];
> NSInteger bytesRead = [is read:buf maxLength:1024];
> if (bytesRead == -1) {
> NSLog(@"Network read error");
> } else if (bytesRead == 0) {
> NSLog(@"No buffer received");
> } else {
> [receivedData appendBytes:buf length:bytesRead];
> BOOL parserResult = [xmlParser parse];
> if (parserResult == NO) {
> NSLog(@"Unable to parse XML");
> }
> }
> }
> break;
> }
> default:
> break;
> }
> }
>
> @end
> _______________________________________________
>
> Cocoa-dev mailing list (email@hidden)
>
> Please do not post admin requests or moderator comments to the list.
> Contact the moderators at cocoa-dev-admins(at)lists.apple.com
>
> Help/Unsubscribe/Update your Subscription:
>
> This email sent to email@hidden
_______________________________________________
Cocoa-dev mailing list (email@hidden)
Please do not post admin requests or moderator comments to the list.
Contact the moderators at cocoa-dev-admins(at)lists.apple.com
Help/Unsubscribe/Update your Subscription:
This email sent to email@hidden