diff --git a/src/crystal/event_loop/file_descriptor.cr b/src/crystal/event_loop/file_descriptor.cr index 75a455a89c9a..633fa180db68 100644 --- a/src/crystal/event_loop/file_descriptor.cr +++ b/src/crystal/event_loop/file_descriptor.cr @@ -10,7 +10,7 @@ abstract class Crystal::EventLoop abstract def read(file_descriptor : Crystal::System::FileDescriptor, slice : Bytes) : Int32 # Blocks the current fiber until the file descriptor is ready for read. - abstract def wait_readable(file_descriptor Crystal::System::FileDescriptor) : Nil + abstract def wait_readable(file_descriptor : Crystal::System::FileDescriptor) : Nil # Writes at least one byte from *slice* to the file descriptor. # @@ -21,7 +21,7 @@ abstract class Crystal::EventLoop abstract def write(file_descriptor : Crystal::System::FileDescriptor, slice : Bytes) : Int32 # Blocks the current fiber until the file descriptor is ready for write. - abstract def wait_writable(file_descriptor Crystal::System::FileDescriptor) : Nil + abstract def wait_writable(file_descriptor : Crystal::System::FileDescriptor) : Nil # Closes the file descriptor resource. abstract def close(file_descriptor : Crystal::System::FileDescriptor) : Nil diff --git a/src/crystal/event_loop/libevent.cr b/src/crystal/event_loop/libevent.cr index f57685a41959..636d01331624 100644 --- a/src/crystal/event_loop/libevent.cr +++ b/src/crystal/event_loop/libevent.cr @@ -132,6 +132,7 @@ class Crystal::EventLoop::LibEvent < Crystal::EventLoop socket.evented_wait_writable do raise IO::TimeoutError.new("Write timed out") end + end def receive_from(socket : ::Socket, slice : Bytes) : Tuple(Int32, ::Socket::Address) sockaddr = Pointer(LibC::SockaddrStorage).malloc.as(LibC::Sockaddr*)