Stream

Object Hierarchy:

Description:

OLLMrpc.Bin.register("Pair", typeof(Pair));

var mem = new GLib.MemoryOutputStream.resizable();
var out_stream = new GLib.DataOutputStream(mem);
var write_bin = new OLLMrpc.Bin.Stream(null, out_stream);
write_bin.write(new Pair() { name = "alpha", count = 42 });
out_stream.close();

var read_bin = new OLLMrpc.Bin.Stream(
    new GLib.DataInputStream(
        new GLib.MemoryInputStream.from_bytes(mem.steal_as_bytes())),
    null);
var parsed = read_bin.parse() as Pair;

Content:

Constants:

• public const uint16 TOKEN_END
• public const uint16 TOKEN_REG_KEY
• public const uint16 TOKEN_REG_TYPE
• public const uint8 TOKEN_SCM_RIGHTS

Properties:

• public unowned Client client { get; set; }
  Client Stream: the OLLMrpc.Client that owns OLLMrpc.Client.proxies.
• public unowned Connection connection { get; set; }
  Server Stream: the OLLMrpc.Transport.Connection that owns OLLMrpc.Transport.Connection.lease_ids.
• public DataInputStream? in_stream { get; construct; }
• public bool is_server { get; construct; }
  True on the daemon/accepting end — allocates odd wire name tokens. Client end leaves this false and allocates even tokens.
• public bool live_handles { get; set; }
• public Mode mode { get; set; }
  Copied from Json.mode for GObject decode on this stream.
• public DataOutputStream? out_stream { get; construct; }
• public Socket? socket { get; set; }

Creation methods:

• public Stream (DataInputStream? in_stream, DataOutputStream? out_stream, bool is_server = false)

Methods:

• public Serializable parse () throws Error
• public Object parse_object (Type object_type = INVALID, Type expected_type = INVALID) throws Error
  Read one object body after its GLib.Type.OBJECT type byte.
• public ArrayList<Object> parse_object_array () throws Error
  Homogeneous object-array body after wire byte 0xD0: element class, count, then one property stream per element.
• public Type read_gtype () throws Error
  Read reg_id after an object type byte; return registered gtype.
• public void write (Serializable obj, Buffer? buffer = null) throws Error
• public void write_gtype (Type object_type, uint8 type_byte = ( uint8) OBJECT) throws Error
• public void write_tag (string prop_name) throws Error

Inherited Members: