1 files changed, 92 insertions, 0 deletions
diff --git a/SmartDeviceLink/SDLStreamDelegate.m b/SmartDeviceLink/SDLStreamDelegate.m
new file mode 100644
index 000000000..6c2db6c34
--- /dev/null
+++ b/SmartDeviceLink/SDLStreamDelegate.m
@@ -0,0 +1,92 @@
+//
+//  SDLtreamDelegate.m
+//
+
+#import "SDLStreamDelegate.h"
+#import "SDLDebugTool.h"
+
+@interface SDLStreamDelegate () {
+    dispatch_queue_t _input_stream_queue;
+}
+
+@end
+
+
+@implementation SDLStreamDelegate
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _streamOpenHandler = defaultStreamOpenHandler;
+        _streamHasBytesHandler = defaultStreamHasBytesHandler;
+        _streamHasSpaceHandler = defaultStreamHasSpaceHandler;
+        _streamErrorHandler = defaultStreamErrorHandler;
+        _streamEndHandler = defaultStreamErrorHandler;
+
+        _input_stream_queue = dispatch_queue_create("com.sdl.streamdelegate.input", DISPATCH_QUEUE_SERIAL);
+    }
+    return self;
+}
+
+- (void)stream:(NSStream *)stream handleEvent:(NSStreamEvent)eventCode {
+    switch (eventCode) {
+        case NSStreamEventOpenCompleted: {
+            if (_streamOpenHandler) {
+                self.streamOpenHandler(stream);
+            }
+            break;
+        }
+        case NSStreamEventHasBytesAvailable: {
+            if (_streamHasBytesHandler) {
+                dispatch_async(_input_stream_queue, ^{
+                    self.streamHasBytesHandler((NSInputStream *)stream);
+                });
+            }
+            break;
+        }
+        case NSStreamEventHasSpaceAvailable: {
+            if (_streamHasSpaceHandler) {
+                self.streamHasSpaceHandler((NSOutputStream *)stream);
+            }
+            break;
+        }
+        case NSStreamEventErrorOccurred: {
+            if (_streamErrorHandler) {
+                self.streamErrorHandler(stream);
+            }
+            break;
+        }
+        case NSStreamEventEndEncountered: {
+            if (_streamEndHandler) {
+                self.streamEndHandler(stream);
+            }
+            break;
+        }
+        case NSStreamEventNone:
+        default: {
+            break;
+        }
+    }
+}
+
+SDLStreamOpenHandler defaultStreamOpenHandler = ^(NSStream *stream) {
+    [SDLDebugTool logInfo:@"Stream Event Open"];
+};
+
+SDLStreamHasBytesHandler defaultStreamHasBytesHandler = ^(NSInputStream *istream) {
+    [SDLDebugTool logInfo:@"Stream Event Has Bytes"];
+};
+
+SDLStreamHasSpaceHandler defaultStreamHasSpaceHandler = ^(NSOutputStream *ostream) {
+
+};
+
+SDLStreamErrorHandler defaultStreamErrorHandler = ^(NSStream *stream) {
+    [SDLDebugTool logInfo:@"Stream Event Error"];
+};
+
+SDLStreamEndHandler defaultStreamEndHandler = ^(NSStream *stream) {
+    [SDLDebugTool logInfo:@"Stream Event End"];
+};
+
+@end