Module: AbortedStream

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

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Attribute Details

#exceptionObject

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