no message

SSignalKit/SQueue.h

@@ -6,6 +6,8 @@
 + (SQueue *)concurrentDefaultQueue;
 + (SQueue *)concurrentBackgroundQueue;
 
++ (SQueue *)wrapConcurrentNativeQueue:(dispatch_queue_t)nativeQueue;
+
 - (void)dispatch:(dispatch_block_t)block;
 
 - (dispatch_queue_t)_dispatch_queue;

SSignalKit/SQueue.m

@@ -50,6 +50,11 @@ static const void *SQueueSpecificKey = &SQueueSpecificKey;
     return queue;
 }
 
++ (SQueue *)wrapConcurrentNativeQueue:(dispatch_queue_t)nativeQueue
+{
+    return [[SQueue alloc] initWithNativeQueue:nativeQueue queueSpecific:NULL];
+}
+
 - (instancetype)init
 {
     dispatch_queue_t queue = dispatch_queue_create(NULL, NULL);

SSignalKit/SSignal+Catch.m

@@ -10,15 +10,15 @@
 {
     return [[SSignal alloc] initWithGenerator:^id<SDisposable> (SSubscriber *subscriber)
     {
-        SMetaDisposable *disposable = [[SMetaDisposable alloc] init];
+        SDisposableSet *disposable = [[SDisposableSet alloc] init];
         
-        [disposable setDisposable:[self startWithNext:^(id next)
+        [disposable add:[self startWithNext:^(id next)
         {
             [subscriber putNext:next];
         } error:^(id error)
         {
             SSignal *signal = f(error);
-            [disposable setDisposable:[signal startWithNext:^(id next)
+            [disposable add:[signal startWithNext:^(id next)
             {
                 [subscriber putNext:next];
             } error:^(id error)

SSignalKit/SSignal+Single.m

@@ -7,6 +7,7 @@
     return [[SSignal alloc] initWithGenerator:^id<SDisposable> (SSubscriber *subscriber)
     {
         [subscriber putNext:next];
+        [subscriber putCompletion];
         return nil;
     }];
 }