Module: AbortedStream

Defined in:
lib/rbbt/util/misc/concurrent_stream.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Attribute Details

#exception ⇒ Object

Returns the value of attribute exception.



2
3
4
 
# File 'lib/rbbt/util/misc/concurrent_stream.rb', line 2

def exception
  @exception
end

Class Method Details

.setup(obj, exception = nil) ⇒ Object 



3
4
5
6
 
# File 'lib/rbbt/util/misc/concurrent_stream.rb', line 3

def self.setup(obj, exception = nil)
  obj.extend AbortedStream
  obj.exception = exception
end