Fix code style

Author: tonyfreeman

Sources/Event/Epoll.swift

@@ -13,7 +13,7 @@ extension Descriptor {
         guard getrlimit(Int32(RLIMIT_NOFILE.rawValue), &rlim) >= 0 else {
             return 0
         }
-        return Int(rlim.rlim_max);
+        return Int(rlim.rlim_max)
     }
 }
 

Sources/Event/Kqueue.swift

@@ -53,7 +53,7 @@ public struct TypeOptions: OptionSet {
     public static let write = TypeOptions(rawValue: Int16(EVFILT_WRITE))
 }
 
-fileprivate struct FlagOptions: OptionSet  {
+private struct FlagOptions: OptionSet {
     let rawValue: UInt16
 
     static let add = FlagOptions(rawValue: UInt16(EV_ADD))

Sources/Event/Poller.swift

@@ -20,7 +20,7 @@ extension PollerProtocol {
 }
 
 extension Poller: Equatable {
-    public static func ==(lhs: Poller, rhs: Poller) -> Bool {
+    public static func == (lhs: Poller, rhs: Poller) -> Bool {
         return lhs.descriptor == rhs.descriptor
     }
 }

Sources/Fiber/FiberLoop+Dispatch.swift

@@ -19,7 +19,7 @@ extension FiberLoop {
         guard try wait(for: fd.1, event: .write, deadline: deadline) == .ready
         else { throw Error.canceled }
 
-        var result: Result<T>? = nil
+        var result: Result<T>?
 
         let workItem = DispatchWorkItem(qos: qos) {
             fiber {
@@ -51,9 +51,8 @@ extension FiberLoop {
     fileprivate func pipe() throws -> (Descriptor, Descriptor) {
         var fd: (Int32, Int32) = (0, 0)
         try withUnsafeMutablePointer(to: &fd) { pointer in
-            try pointer.withMemoryRebound(to: Int32.self, capacity: 2)
-            { pointer in
-                guard Platform.pipe(pointer) != -1 else {
+            try pointer.withMemoryRebound(to: Int32.self, capacity: 2) {
+                guard Platform.pipe($0) != -1 else {
                     throw SystemError()
                 }
             }

Sources/Fiber/FiberLoop.swift

@@ -4,8 +4,6 @@ import Event
 import Platform
 import ListEntry
 
-@_exported import enum Event.IOEvent
-
 public class FiberLoop {
     var poller = Poller()
     var watchers: UnsafeMutableBufferPointer<Watchers>
@@ -32,7 +30,7 @@ public class FiberLoop {
     public class var current: FiberLoop {
         Thread.isMain
             ? main
-            : FiberLoop._current.get() { FiberLoop() }
+            : FiberLoop._current.get { FiberLoop() }
     }
 
     var deadline = Time.distantFuture
@@ -162,8 +160,8 @@ public class FiberLoop {
     public func wait(
         for socket: Descriptor,
         event: IOEvent,
-        deadline: Time) throws -> Fiber.State
-    {
+        deadline: Time
+    ) throws -> Fiber.State {
         try insertWatcher(for: socket, event: event, deadline: deadline)
         scheduler.suspend()
         removeWatcher(for: socket, event: event)
@@ -212,11 +210,9 @@ public class FiberLoop {
         } else if deadline < sleeping.minDeadline! {
             sleeping.insert(currentFiber.pointee.watcherEntry)
         } else {
-            for watcher in sleeping.pointee {
-                if deadline < watcher.deadline {
-                    watcher.insert(currentFiber.pointee.watcherEntry)
-                    return
-                }
+            for watcher in sleeping.pointee where deadline < watcher.deadline {
+                watcher.insert(currentFiber.pointee.watcherEntry)
+                return
             }
             fatalError("unreachable")
         }
@@ -230,15 +226,15 @@ public class FiberLoop {
 extension UnsafeMutableBufferPointer where Element == FiberLoop.Watchers {
     typealias Watchers = FiberLoop.Watchers
 
-    subscript(_ descriptor: Descriptor) -> Watchers{
+    subscript(_ descriptor: Descriptor) -> Watchers {
         get { self[Int(descriptor.rawValue)] }
         set { self[Int(descriptor.rawValue)] = newValue }
     }
 
     static func allocate(
         repeating element: Watchers,
-        count: Int) -> UnsafeMutableBufferPointer<Watchers>
-    {
+        count: Int
+    ) -> UnsafeMutableBufferPointer<Watchers> {
         let pointer = UnsafeMutablePointer<Watchers>.allocate(capacity: count)
         pointer.initialize(repeating: element, count: count)
 
@@ -264,7 +260,7 @@ where Pointee == ListEntry<UnsafeMutablePointer<Fiber>> {
 }
 
 extension FiberLoop: Equatable {
-    public static func ==(lhs: FiberLoop, rhs: FiberLoop) -> Bool {
+    public static func == (lhs: FiberLoop, rhs: FiberLoop) -> Bool {
         return lhs.poller == rhs.poller
     }
 }

Sources/Fiber/Scheduler.swift

@@ -10,7 +10,7 @@ public class Scheduler {
     public class var current: Scheduler {
         Thread.isMain
             ? main
-            : Scheduler._current.get() { Scheduler() }
+            : Scheduler._current.get { Scheduler() }
     }
 
     init() {
@@ -98,8 +98,7 @@ public class Scheduler {
     }
 
     @usableFromInline
-    func schedule(fiber: UnsafeMutablePointer<Fiber>, state: Fiber.State)
-    {
+    func schedule(fiber: UnsafeMutablePointer<Fiber>, state: Fiber.State) {
         fiber.pointee.state = state
         ready.append(fiber)
     }

Tests/FiberTests/ChannelTests.swift

@@ -118,7 +118,7 @@ class ChannelTests: TestCase {
     func testChannelCloseHasReader() {
         let channel = Channel<Int>(capacity: 10)
 
-        var first: Int? = nil
+        var first: Int?
         fiber {
             first = channel.read()
         }
@@ -138,7 +138,7 @@ class ChannelTests: TestCase {
     func testChannelCloseHasWaitingReader() {
         let channel = Channel<Int>()
 
-        var result: Optional<Int> = 42
+        var result: Int? = 42
         fiber {
             result = channel.read()
         }

Tests/FiberTests/DispatchTests.swift

@@ -38,7 +38,7 @@ class DispatchTests: TestCase {
         struct TestError: Swift.Error, Equatable {
             let code: Int
         }
-        var testError: TestError? = nil
+        var testError: TestError?
 
         fiber {
             do {

Tests/FiberTests/FiberLoopTests.swift

@@ -64,7 +64,7 @@ class FiberLoopTests: TestCase {
     }
 
     func testPollDeadline() {
-        var result: FiberLoop.Error? = nil
+        var result: FiberLoop.Error?
 
         fiber {
             do {