Class: Going::Push

Inherits:
Operation show all
Defined in:
lib/going/operation/push.rb

Instance Attribute Summary

Attributes inherited from Operation

#message, #select_statement

Instance Method Summary collapse

Methods inherited from Operation

#incomplete?, #initialize, #signal, #wait

Methods included from BooleanAttrReader

#battr_reader

Constructor Details

This class inherits a constructor from Going::Operation

Instance Method Details

#closeObject



8
9
10
11
12
13
# File 'lib/going/operation/push.rb', line 8

def close
  super
  select_statement.secondary_complete do
    fail 'cannot push to a closed channel'
  end
end

#completeObject



3
4
5
6
# File 'lib/going/operation/push.rb', line 3

def complete
  super
  select_statement.complete(&on_complete)
end