//
|
// MQTTDecoder.h
|
// MQTTClient.framework
|
//
|
// Copyright © 2013-2017, Christoph Krey. All rights reserved.
|
//
|
// based on
|
//
|
// Copyright (c) 2011, 2013, 2lemetry LLC
|
//
|
// All rights reserved. This program and the accompanying materials
|
// are made available under the terms of the Eclipse Public License v1.0
|
// which accompanies this distribution, and is available at
|
// http://www.eclipse.org/legal/epl-v10.html
|
//
|
// Contributors:
|
// Kyle Roche - initial API and implementation and/or initial documentation
|
//
|
|
#import <Foundation/Foundation.h>
|
#import "MQTTMessage.h"
|
|
typedef NS_ENUM(unsigned int, MQTTDecoderEvent) {
|
MQTTDecoderEventProtocolError,
|
MQTTDecoderEventConnectionClosed,
|
MQTTDecoderEventConnectionError
|
};
|
|
typedef NS_ENUM(unsigned int, MQTTDecoderState) {
|
MQTTDecoderStateInitializing,
|
MQTTDecoderStateDecodingHeader,
|
MQTTDecoderStateDecodingLength,
|
MQTTDecoderStateDecodingData,
|
MQTTDecoderStateConnectionClosed,
|
MQTTDecoderStateConnectionError,
|
MQTTDecoderStateProtocolError
|
};
|
|
@class MQTTDecoder;
|
|
@protocol MQTTDecoderDelegate <NSObject>
|
|
- (void)decoder:(MQTTDecoder *)sender didReceiveMessage:(NSData *)data;
|
- (void)decoder:(MQTTDecoder *)sender handleEvent:(MQTTDecoderEvent)eventCode error:(NSError *)error;
|
|
@end
|
|
|
@interface MQTTDecoder: NSObject <NSStreamDelegate>
|
|
@property (nonatomic) MQTTDecoderState state;
|
@property (strong, nonatomic) dispatch_queue_t queue;
|
@property (nonatomic) UInt32 length;
|
@property (nonatomic) UInt32 lengthMultiplier;
|
@property (nonatomic) int offset;
|
@property (strong, nonatomic) NSMutableData *dataBuffer;
|
|
@property (weak, nonatomic) id<MQTTDecoderDelegate> delegate;
|
|
- (void)open;
|
- (void)close;
|
- (void)decodeMessage:(NSData *)data;
|
|
@end
|
