Module: Libuv::Stream
Constant Summary collapse
- BACKLOG_ERROR =
"backlog must be an Integer".freeze
- WRITE_ERROR =
"data must be a String".freeze
- STREAM_CLOSED_ERROR =
"unable to write to a closed stream".freeze
- CLOSED_HANDLE_ERROR =
"handle closed before accept called".freeze
Class Method Summary collapse
Instance Method Summary collapse
- #listen(backlog) ⇒ Object
- #progress(callback = nil, &blk) ⇒ Object
- #readable? ⇒ Boolean
-
#shutdown ⇒ Object
Shutsdown the writes on the handle waiting until the last write is complete before triggering the callback.
-
#start_read ⇒ Object
Starts reading from the handle.
-
#stop_read ⇒ Object
Stops reading from the handle.
- #try_write(data) ⇒ Object
- #writable? ⇒ Boolean
- #write(data) ⇒ Object (also: #puts)
Class Method Details
.included(base) ⇒ Object
5 6 7 8 9 10 11 12 |
# File 'lib/libuv/mixins/stream.rb', line 5 def self.included(base) base.define_callback function: :on_listen, params: [:pointer, :int] base.define_callback function: :write_complete, params: [:pointer, :int] base.define_callback function: :on_shutdown, params: [:pointer, :int] base.define_callback function: :on_allocate, params: [:pointer, :size_t, Ext::UvBuf.by_ref] base.define_callback function: :on_read, params: [:pointer, :ssize_t, Ext::UvBuf.by_ref] end |
Instance Method Details
#listen(backlog) ⇒ Object
22 23 24 25 26 27 |
# File 'lib/libuv/mixins/stream.rb', line 22 def listen(backlog) return if @closed assert_type(Integer, backlog, BACKLOG_ERROR) error = check_result ::Libuv::Ext.listen(handle, Integer(backlog), callback(:on_listen)) reject(error) if error end |
#progress(callback = nil, &blk) ⇒ Object
111 112 113 |
# File 'lib/libuv/mixins/stream.rb', line 111 def progress(callback = nil, &blk) @progress = callback || blk end |
#readable? ⇒ Boolean
101 102 103 104 |
# File 'lib/libuv/mixins/stream.rb', line 101 def readable? return false if @closed ::Libuv::Ext.is_readable(handle) > 0 end |
#shutdown ⇒ Object
Shutsdown the writes on the handle waiting until the last write is complete before triggering the callback
44 45 46 47 48 49 |
# File 'lib/libuv/mixins/stream.rb', line 44 def shutdown return if @closed req = ::Libuv::Ext.allocate_request_shutdown error = check_result ::Libuv::Ext.shutdown(req, handle, callback(:on_shutdown, req.address)) reject(error) if error end |
#start_read ⇒ Object
Starts reading from the handle
30 31 32 33 34 |
# File 'lib/libuv/mixins/stream.rb', line 30 def start_read return if @closed error = check_result ::Libuv::Ext.read_start(handle, callback(:on_allocate), callback(:on_read)) reject(error) if error end |
#stop_read ⇒ Object
Stops reading from the handle
37 38 39 40 41 |
# File 'lib/libuv/mixins/stream.rb', line 37 def stop_read return if @closed error = check_result ::Libuv::Ext.read_stop(handle) reject(error) if error end |
#try_write(data) ⇒ Object
51 52 53 54 55 56 57 58 59 60 61 62 63 |
# File 'lib/libuv/mixins/stream.rb', line 51 def try_write(data) assert_type(String, data, WRITE_ERROR) buffer1 = ::FFI::MemoryPointer.from_string(data) buffer = ::Libuv::Ext.buf_init(buffer1, data.respond_to?(:bytesize) ? data.bytesize : data.size) result = ::Libuv::Ext.try_write(handle, buffer, 1) buffer1.free error = check_result result raise error if error return result end |
#writable? ⇒ Boolean
106 107 108 109 |
# File 'lib/libuv/mixins/stream.rb', line 106 def writable? return false if @closed ::Libuv::Ext.is_writable(handle) > 0 end |
#write(data) ⇒ Object Also known as: puts
65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 |
# File 'lib/libuv/mixins/stream.rb', line 65 def write(data) # NOTE:: Similar to udp.rb -> send deferred = @loop.defer if !@closed begin assert_type(String, data, WRITE_ERROR) buffer1 = ::FFI::MemoryPointer.from_string(data) buffer = ::Libuv::Ext.buf_init(buffer1, data.bytesize) # local as this variable will be available until the handle is closed @write_callbacks ||= {} req = ::Libuv::Ext.allocate_request_write @write_callbacks[req.address] = [deferred, buffer1] error = check_result ::Libuv::Ext.write(req, handle, buffer, 1, callback(:write_complete, req.address)) if error @write_callbacks.delete req.address cleanup_callbacks req.address ::Libuv::Ext.free(req) buffer1.free deferred.reject(error) reject(error) # close the handle end rescue => e deferred.reject(e) # this write exception may not be fatal end else deferred.reject(RuntimeError.new(STREAM_CLOSED_ERROR)) end deferred.promise end |