File tree Expand file tree Collapse file tree 1 file changed +0
-31
lines changed
lib/action_cable/subscription_adapter Expand file tree Collapse file tree 1 file changed +0
-31
lines changed Original file line number Diff line number Diff line change @@ -128,37 +128,6 @@ def with_polling_volume
128128 yield
129129 end
130130 end
131-
132- def wake_up
133- interrupt
134- end
135-
136- SELF_PIPE_BLOCK_SIZE = 11
137-
138- def interrupt
139- self_pipe [ :writer ] . write_nonblock ( "." )
140- rescue Errno ::EAGAIN , Errno ::EINTR
141- # Ignore writes that would block and retry
142- # if another signal arrived while writing
143- retry
144- end
145-
146- def interruptible_sleep ( time )
147- if time > 0 && self_pipe [ :reader ] . wait_readable ( time )
148- loop { self_pipe [ :reader ] . read_nonblock ( SELF_PIPE_BLOCK_SIZE ) }
149- end
150- rescue Errno ::EAGAIN , Errno ::EINTR
151- end
152-
153- # Self-pipe for signal-handling (http://cr.yp.to/docs/selfpipe.html)
154- def self_pipe
155- @self_pipe ||= create_self_pipe
156- end
157-
158- def create_self_pipe
159- reader , writer = IO . pipe
160- { reader : reader , writer : writer }
161- end
162131 end
163132 end
164133 end
You can’t perform that action at this time.
0 commit comments