+static VALUE
+stream_serialize (VALUE self)
+{
+ VALUE ret;
+ struct RArray *stream;
+ static ID id_serialize;
+ long i;
+
+ ret = rb_str_new2 ("");
+
+ stream = RARRAY (self);
+ if (!stream->len)
+ return ret;
+
+ if (!id_serialize)
+ id_serialize = rb_intern ("serialize");
+
+ for (i = 0; i < stream->len; i++) {
+ VALUE str = rb_funcall (stream->ptr[i], id_serialize, 0, NULL);
+
+ rb_str_append (ret, str);
+ }
+
+ return ret;
+}
+
+static VALUE
+chunk_serialize (VALUE self)
+{
+ VALUE tmp, ret;
+ unsigned int size, buf_len;
+ unsigned char *buf;
+ struct RString *tag, *data;
+ static ID id_tag, id_data;
+
+ if (!id_tag)
+ id_tag = rb_intern ("@tag");
+
+ if (!id_data)
+ id_data = rb_intern ("@data");
+
+ tmp = rb_ivar_get (self, id_tag);
+ StringValue (tmp);
+ tag = RSTRING (tmp);
+
+ tmp = rb_ivar_get (self, id_data);
+ StringValue (tmp);
+ data = RSTRING (tmp);
+
+ buf_len = 9 + tag->len + data->len;
+ ret = rb_str_buf_new (buf_len);
+
+ buf = RSTRING (ret)->ptr;
+ RSTRING (ret)->len = buf_len;
+
+ memcpy (buf, "CHnK", 4);
+ buf += 4;
+
+ size = tag->len + data->len + 1;
+ size = BSWAP32 (size);
+ memcpy (buf, &size, 4);
+ buf += 4;
+
+ memcpy (buf, tag->ptr, tag->len);
+ buf += tag->len;
+
+ *buf++ = 0;
+
+ memcpy (buf, data->ptr, data->len);
+
+ return ret;
+}
+