From cc5353792d9474f7c5eed58caaaabab85bf1c424 Mon Sep 17 00:00:00 2001
From: Krunoslav Zaher <krunoslav.zaher@gmail.com>
Date: Tue, 11 Aug 2015 09:52:33 +0200
Subject: [PATCH] RxResult -> throws for take

---
 .../Observables/Implementations/Take.swift       | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/RxSwift/RxSwift/Observables/Implementations/Take.swift b/RxSwift/RxSwift/Observables/Implementations/Take.swift
index a60425a5..f8e64639 100644
--- a/RxSwift/RxSwift/Observables/Implementations/Take.swift
+++ b/RxSwift/RxSwift/Observables/Implementations/Take.swift
@@ -31,18 +31,18 @@ class TakeCountSink<ElementType, O: ObserverType where O.Element == ElementType>
             if remaining > 0 {
                 remaining--
                 
-                trySendNext(observer, value)
+                observer?.on(.Next(value))
             
                 if remaining == 0 {
-                    trySendCompleted(observer)
+                    observer?.on(.Completed)
                     self.dispose()
                 }
             }
         case .Error:
-            trySend(observer, event)
+            observer?.on(event)
             self.dispose()
         case .Completed:
-            trySend(observer, event)
+            observer?.on(event)
             self.dispose()
         }
     }
@@ -83,12 +83,12 @@ class TakeTimeSink<ElementType, S: Scheduler, O: ObserverType where O.Element ==
         lock.performLocked {
             switch event {
             case .Next(let value):
-                trySendNext(observer, value)
+                observer?.on(.Next(value))
             case .Error:
-                trySend(observer, event)
+                observer?.on(event)
                 self.dispose()
             case .Completed:
-                trySend(observer, event)
+                observer?.on(event)
                 self.dispose()
             }
         }
@@ -96,7 +96,7 @@ class TakeTimeSink<ElementType, S: Scheduler, O: ObserverType where O.Element ==
     
     func tick() {
         lock.performLocked {
-            trySendCompleted(self.observer)
+            self.observer?.on(.Completed)
             self.dispose()
         }
     }