File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -383,7 +383,7 @@ def write_message_by_block(&block)
383
383
len = writing {
384
384
using_each_crlf_line {
385
385
begin
386
- block . call ( WriteAdapter . new ( self , :write_message_0 ) )
386
+ block . call ( WriteAdapter . new ( self . method ( :write_message_0 ) ) )
387
387
rescue LocalJumpError
388
388
# allow `break' from writer block
389
389
end
@@ -447,17 +447,16 @@ def buffer_filling(buf, src)
447
447
# The writer adapter class
448
448
#
449
449
class WriteAdapter
450
- def initialize ( socket , method )
451
- @socket = socket
452
- @method_id = method
450
+ def initialize ( writer )
451
+ @writer = writer
453
452
end
454
453
455
454
def inspect
456
- "#<#{ self . class } socket =#{ @socket . inspect } >"
455
+ "#<#{ self . class } writer =#{ @writer . inspect } >"
457
456
end
458
457
459
458
def write ( str )
460
- @socket . __send__ ( @method_id , str )
459
+ @writer . call ( str )
461
460
end
462
461
463
462
alias print write
You can’t perform that action at this time.
0 commit comments