Method: AMQ::Protocol::Channel::Flow.decode
- Defined in:
- lib/amq/protocol/client.rb
.decode(data) ⇒ Object
718 719 720 721 722 723 724 |
# File 'lib/amq/protocol/client.rb', line 718 def self.decode(data) offset = offset = 0 # self-assigning offset to eliminate "assigned but unused variable" warning even if offset is not used in this method bit_buffer = data[offset, 1].unpack(PACK_CHAR).first offset += 1 active = (bit_buffer & (1 << 0)) != 0 self.new(active) end |