Class: Arf::RPC::StreamError

Inherits:
BaseMessage show all
Defined in:
lib/arf/rpc/stream_error.rb

Instance Method Summary collapse

Methods inherited from BaseMessage

#decode_bytes, #decode_string, #decode_uint16, encode, #encode_bytes, #encode_string, #encode_uint16, has_metadata, has_status, has_streaming, #initialize, initialize_from, kind, message_by_kind, register

Constructor Details

This class inherits a constructor from Arf::RPC::BaseMessage

Instance Method Details

#decode(data) ⇒ Object 



17
18
19
20
 
# File 'lib/arf/rpc/stream_error.rb', line 17

def decode(data)
  @status = decode_uint16(data)
  @metadata = Metadata.new.decode(data)
end

#encode ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/arf/rpc/stream_error.rb', line 10

def encode
  IO::Buffer.new
    .write_raw(encode_uint16(@status))
    .write_raw(metadata.encode)
    .string
end