Remove extra newlines;

src/operators/all.lua

@@ -26,4 +26,3 @@ function Observable:all(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/amb.lua

@@ -48,4 +48,3 @@ function Observable.amb(a, b, ...)
     end)
   end):amb(...)
 end
-

src/operators/average.lua

@@ -26,4 +26,3 @@ function Observable:average()
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/buffer.lua

@@ -38,4 +38,3 @@ function Observable:buffer(size)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/catch.lua

@@ -38,4 +38,3 @@ function Observable:catch(handler)
     return subscription
   end)
 end
-

src/operators/combineLatest.lua

@@ -52,4 +52,3 @@ function Observable:combineLatest(...)
     end
   end)
 end
-

src/operators/compact.lua

@@ -6,4 +6,3 @@ local util = require 'util'
 function Observable:compact()
   return self:filter(util.identity)
 end
-

src/operators/concat.lua

@@ -30,4 +30,3 @@ function Observable:concat(other, ...)
     return self:subscribe(onNext, onError, chain)
   end)
 end
-

src/operators/contains.lua

@@ -40,4 +40,3 @@ function Observable:contains(value)
     return subscription
   end)
 end
-

src/operators/count.lua

@@ -28,4 +28,3 @@ function Observable:count(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/distinct.lua

@@ -25,4 +25,3 @@ function Observable:distinct()
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/distinctUntilChanged.lua

@@ -31,4 +31,3 @@ function Observable:distinctUntilChanged(comparator)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/filter.lua

@@ -25,4 +25,3 @@ function Observable:filter(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/find.lua

@@ -26,4 +26,3 @@ function Observable:find(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/first.lua

@@ -5,4 +5,3 @@ local Observable = require 'observable'
 function Observable:first()
   return self:take(1)
 end
-

src/operators/flatten.lua

@@ -25,4 +25,3 @@ function Observable:flatten()
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/last.lua

@@ -28,4 +28,3 @@ function Observable:last()
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/map.lua

@@ -23,4 +23,3 @@ function Observable:map(callback)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/max.lua

@@ -5,4 +5,3 @@ local Observable = require 'observable'
 function Observable:max()
   return self:reduce(math.max)
 end
-

src/operators/merge.lua

@@ -32,4 +32,3 @@ function Observable:merge(...)
     end
   end)
 end
-

src/operators/min.lua

@@ -5,4 +5,3 @@ local Observable = require 'observable'
 function Observable:min()
   return self:reduce(math.min)
 end
-

src/operators/pack.lua

@@ -6,4 +6,3 @@ local util = require 'util'
 function Observable:pack()
   return self:map(util.pack)
 end
-

src/operators/partition.lua

@@ -8,4 +8,3 @@ local Observable = require 'observable'
 function Observable:partition(predicate)
   return self:filter(predicate), self:reject(predicate)
 end
-

src/operators/pluck.lua

@@ -24,4 +24,3 @@ function Observable:pluck(key, ...)
     return self:subscribe(onNext, onError, onCompleted)
   end):pluck(...)
 end
-

src/operators/reduce.lua

@@ -33,4 +33,3 @@ function Observable:reduce(accumulator, seed)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/reject.lua

@@ -26,4 +26,3 @@ function Observable:reject(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/skip.lua

@@ -29,4 +29,3 @@ function Observable:skip(n)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/skipUntil.lua

@@ -34,4 +34,3 @@ function Observable:skipUntil(other)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/skipWhile.lua

@@ -31,4 +31,3 @@ function Observable:skipWhile(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/take.lua

@@ -35,4 +35,3 @@ function Observable:take(n)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/takeUntil.lua

@@ -22,4 +22,3 @@ function Observable:takeUntil(other)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/takeWhile.lua

@@ -33,4 +33,3 @@ function Observable:takeWhile(predicate)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/tap.lua

@@ -31,4 +31,3 @@ function Observable:tap(_onNext, _onError, _onCompleted)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/unpack.lua

@@ -6,4 +6,3 @@ local util = require 'util'
 function Observable:unpack()
   return self:map(util.unpack)
 end
-

src/operators/unwrap.lua

@@ -23,4 +23,3 @@ function Observable:unwrap()
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/window.lua

@@ -29,4 +29,3 @@ function Observable:window(size)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-

src/operators/with.lua

@@ -37,4 +37,3 @@ function Observable:with(...)
     return self:subscribe(onNext, onError, onCompleted)
   end)
 end
-