Use ImmediateOnMainExecutionContext as default context for operations

Author: srdanrasic

README.md

@@ -172,7 +172,7 @@ Operation can send any number of `.Next` events followed by one terminating even
 Creating the operation doesn't do any work by itself. To start producing results, operation has to be started. Operation will be automatically started when you register an observer to it.
 
 ```swift
-fetchImage(url: ...).observe(on: Queue.main.contex) { event in
+fetchImage(url: ...).observe { event in
   switch event {
     case .Next(let image):
   	  print("Operation produced an image \(image).")
@@ -184,7 +184,7 @@ fetchImage(url: ...).observe(on: Queue.main.contex) { event in
 }
 ```
 
-> When you register the observer to the operation you must explicitly provide execution context onto which events will be dispatched. This differs from observing observables where the main queue context is set as the default one because it encourages us to think about threads (queues) and forces us to explicitly define where do we want to perform the side effects.
+> Observers registered with `observe` method will be by default invoked on the main thread (queue). You can change default behaviour by passing another [execution context](#threading) to the `observe` method.
 
 The observer you register with the operation is actually the one that will be passed to the closure that was provided in operation constructor (the one that does the actual work) - just wrapped into a struct that simplifies sending result. You see how the operation is just a light wrapper around a closure, but that abstraction enables powerful paradigm.
 
@@ -193,7 +193,7 @@ The observer you register with the operation is actually the one that will be pa
 When you're interested in just results of the operation and you don't care when it completes or if it fails, you can use `*Next` family of methods. To observe results of the operation, you would use `observeNext`.
 
 ```swift
-fetchImage(url: ...).observeNext(on: Queue.main.contex) { image in
+fetchImage(url: ...).observeNext { image in
   imageView.image = image
 }
 ```
@@ -212,7 +212,7 @@ fetchImage(url: ...).bindNextTo(imageView)
 Whenever the observer is registered, the operation starts all over again. To share results of a single operation run, use `shareNext` method.
 
 ```swift
-let image = fetchImage(url: ...).shareNext(on: Queue.main.context)
+let image = fetchImage(url: ...).shareNext
 image.bindTo(imageView1)
 image.bindTo(imageView2)
 ```
@@ -250,7 +250,7 @@ authenticate(username: ..., password: ...)
   .flatMap(.Latest) { token in
     return fetchCurrentUser(token)
   }
-  .observeNext(on: Queue.main.context) { user in
+  .observeNext { user in
     print("Authenticated as \(user.fullname).")
   }
 ```

ReactiveKit.podspec

@@ -1,12 +1,12 @@
 Pod::Spec.new do |s|
   s.name             = "ReactiveKit"
-  s.version          = "1.0.2"
+  s.version          = "1.0.3"
   s.summary          = "A Swift Reactive Programming Framework"
   s.description      = "ReactiveKit is a collection of Swift frameworks for reactive and functional reactive programming."
   s.homepage         = "https://github.com/ReactiveKit/ReactiveKit"
   s.license          = 'MIT'
   s.author           = { "Srdan Rasic" => "[email protected]" }
-  s.source           = { :git => "https://github.com/ReactiveKit/ReactiveKit.git", :tag => "v1.0.2" }
+  s.source           = { :git => "https://github.com/ReactiveKit/ReactiveKit.git", :tag => "v1.0.3" }
 
   s.ios.deployment_target       = '8.0'
   s.osx.deployment_target       = '10.9'

ReactiveKit.xcodeproj/project.pbxproj

@@ -196,7 +196,7 @@
 		ECBCCE061BEB6BBE00723476 /* StreamType.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = StreamType.swift; sourceTree = "<group>"; };
 		ECBCCE2A1BEB6BE100723476 /* NoError.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; name = NoError.swift; path = ../Operation/NoError.swift; sourceTree = "<group>"; };
 		ECBCCE2B1BEB6BE100723476 /* Stream+Operation.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = "Stream+Operation.swift"; sourceTree = "<group>"; };
-		ECBCCE2C1BEB6BE100723476 /* Operation.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Operation.swift; sourceTree = "<group>"; };
+		ECBCCE2C1BEB6BE100723476 /* Operation.swift */ = {isa = PBXFileReference; fileEncoding = 4; indentWidth = 2; lastKnownFileType = sourcecode.swift; path = Operation.swift; sourceTree = "<group>"; tabWidth = 2; };
 		ECBCCE2D1BEB6BE100723476 /* OperationEvent.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = OperationEvent.swift; sourceTree = "<group>"; };
 		ECBCCE2E1BEB6BE100723476 /* OperationSink.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = OperationSink.swift; sourceTree = "<group>"; };
 /* End PBXFileReference section */

ReactiveKit/Info.plist

@@ -15,7 +15,7 @@
 	<key>CFBundlePackageType</key>
 	<string>FMWK</string>
 	<key>CFBundleShortVersionString</key>
-	<string>1.0.2</string>
+	<string>1.0.3</string>
 	<key>CFBundleSignature</key>
 	<string>????</string>
 	<key>CFBundleVersion</key>

ReactiveKit/Operation/Operation.swift

@@ -46,7 +46,11 @@ public struct Operation<Value, Error: ErrorType>: OperationType {
       })
     }
   }
-  
+
+  public func observe(observer: OperationEvent<Value, Error> -> ()) -> DisposableType {
+    return observe(on: ImmediateOnMainExecutionContext, observer: observer)
+  }
+
   public func observe(on context: ExecutionContext, observer: OperationEvent<Value, Error> -> ()) -> DisposableType {
     return stream.observe(on: context, observer: observer)
   }
@@ -102,7 +106,7 @@ public extension OperationType {
     }
   }
 
-  public func observeNext(on context: ExecutionContext, observer: Value -> ()) -> DisposableType {
+  public func observeNext(on context: ExecutionContext = ImmediateOnMainExecutionContext, observer: Value -> ()) -> DisposableType {
     return self.observe(on: context) { event in
       switch event {
       case .Next(let event):
@@ -112,7 +116,7 @@ public extension OperationType {
     }
   }
 
-  public func observeError(on context: ExecutionContext, observer: Error -> ()) -> DisposableType {
+  public func observeError(on context: ExecutionContext = ImmediateOnMainExecutionContext, observer: Error -> ()) -> DisposableType {
     return self.observe(on: context) { event in
       switch event {
       case .Failure(let error):
@@ -123,7 +127,7 @@ public extension OperationType {
   }
 
   @warn_unused_result
-  public func shareNext(limit: Int = Int.max, context: ExecutionContext = Queue.main.context) -> ActiveStream<Value> {
+  public func shareNext(limit: Int = Int.max, context: ExecutionContext = ImmediateOnMainExecutionContext) -> ActiveStream<Value> {
     return create(limit) { observer in
       return self.observeNext(on: context, observer: observer)
     }

ReactiveKit/Streams/ActiveStream.swift

@@ -66,10 +66,10 @@ public class ActiveStream<Event>: ActiveStreamType {
   }
 
   public func observe(observer: Observer) -> DisposableType {
-    return observe(on: ImmediateExecutionContext, observer: observer)
+    return observe(on: ImmediateOnMainExecutionContext, observer: observer)
   }
 
-  public func observe(on context: ExecutionContext, observer: Observer) -> DisposableType {
+  public func observe(on context: ExecutionContext = ImmediateOnMainExecutionContext, observer: Observer) -> DisposableType {
     selfReference?.retain()
 
     let observer = { e in context { observer(e) } }