Class: DTAS::Pipe
- Includes:
- WritableIter
- Defined in:
- lib/dtas/pipe.rb
Overview
pipe wrapper for -player sinks
Direct Known Subclasses
Constant Summary
Constants inherited from Nonblock
Instance Attribute Summary collapse
-
#sink ⇒ Object
Returns the value of attribute sink.
Attributes included from WritableIter
Class Method Summary collapse
Instance Method Summary collapse
-
#nonblock? ⇒ Boolean
avoid syscall, we never change IO#nonblock= directly.
- #pipe_size ⇒ Object
- #pipe_size=(nr) ⇒ Object
Methods included from WritableIter
#ready_write_optimized?, #wait_writable_prepare, #writable_iter, #writable_iter_init
Methods inherited from Nonblock
#read_nonblock, #write_nonblock
Instance Attribute Details
#sink ⇒ Object
Returns the value of attribute sink.
15 16 17 |
# File 'lib/dtas/pipe.rb', line 15 def sink @sink end |
Class Method Details
.new ⇒ Object
17 18 19 20 21 |
# File 'lib/dtas/pipe.rb', line 17 def self.new _, w = rv = pipe w.writable_iter_init rv end |
Instance Method Details
#nonblock? ⇒ Boolean
avoid syscall, we never change IO#nonblock= directly
33 34 35 |
# File 'lib/dtas/pipe.rb', line 33 def nonblock? false end |
#pipe_size ⇒ Object
28 29 30 |
# File 'lib/dtas/pipe.rb', line 28 def pipe_size fcntl(SleepyPenguin::F_GETPIPE_SZ) end |
#pipe_size=(nr) ⇒ Object
23 24 25 26 |
# File 'lib/dtas/pipe.rb', line 23 def pipe_size=(nr) defined?(SleepyPenguin::F_SETPIPE_SZ) and fcntl(SleepyPenguin::F_SETPIPE_SZ, nr) end |