Class: Riser::LoggingStream

Inherits:
Stream
  • Object
show all
Defined in:
lib/riser/stream.rb

Instance Method Summary collapse

Methods inherited from Stream

#<<, #flush, #to_io

Constructor Details

#initialize(io, logger) ⇒ LoggingStream

Returns a new instance of LoggingStream.



77
78
79
80
 
# File 'lib/riser/stream.rb', line 77

def initialize(io, logger)
  super(io)
  @logger = logger
end

Instance Method Details

#close ⇒ Object 



105
106
107
108
 
# File 'lib/riser/stream.rb', line 105

def close
  @logger.info('close')
  super
end

#gets ⇒ Object 



82
83
84
85
86
 
# File 'lib/riser/stream.rb', line 82

def gets
  line = super
  @logger.info("r #{line.inspect}")
  line
end

#read(size) ⇒ Object 



88
89
90
91
92
 
# File 'lib/riser/stream.rb', line 88

def read(size)
  data = super
  @logger.info("r #{data.inspect}")
  data
end

#readpartial(maxlen, outbuf = nil) ⇒ Object 



94
95
96
97
98
 
# File 'lib/riser/stream.rb', line 94

def readpartial(maxlen, outbuf=nil)
  data = super
  @logger.info("r #{data.inspect}")
  data
end

#write(message) ⇒ Object 



100
101
102
103
 
# File 'lib/riser/stream.rb', line 100

def write(message)
  @logger.info("w #{message.inspect}")
  super
end