diff --git a/internal/lvgen/procedures.tmpl b/internal/lvgen/procedures.tmpl
index 4763c86..372b0b1 100644
--- a/internal/lvgen/procedures.tmpl
+++ b/internal/lvgen/procedures.tmpl
@@ -23,6 +23,7 @@ package libvirt
 import (
 	"bytes"
 	"fmt"
+	"io"
 
 	"github.com/davecgh/go-xdr/xdr2"
 	"github.com/digitalocean/go-libvirt/internal/constants"
@@ -126,9 +127,15 @@ func decodeTypedParams(dec *xdr.Decoder) ([]TypedParam, error) {
 	return params, nil
 }
 
-{{range .Procs}}
+{{range $proc := .Procs}}
 // {{.Name}} is the go wrapper for {{.LVName}}.
-func (l *Libvirt) {{.Name}}({{range $ix, $arg := .Args}}{{if $ix}}, {{end}}{{.Name}} {{.Type}}{{end}}) ({{range .Ret}}r{{.Name}} {{.Type}}, {{end}}err error) {
+func (l *Libvirt) {{.Name}}(
+  {{- range $ix, $arg := .Args}}
+    {{- if (eq $ix $proc.WriteStreamIdx)}}{{if $ix}}, {{end}}outStream io.Reader{{end}}
+    {{- if (eq $ix $proc.ReadStreamIdx)}}{{if $ix}}, {{end}}inStream io.Writer{{end}}
+    {{- if $ix}}, {{end}}{{.Name}} {{.Type}}
+  {{- end -}}
+) ({{range .Ret}}r{{.Name}} {{.Type}}, {{end}}err error) {
 	var buf []byte
 {{if .ArgsStruct}}
 	args := {{.ArgsStruct}} {
@@ -141,7 +148,10 @@ func (l *Libvirt) {{.Name}}({{range $ix, $arg := .Args}}{{if $ix}}, {{end}}{{.Na
 	}
 {{end}}
 {{if .RetStruct}}	var r response{{end}}
-	{{if .RetStruct}}r{{else}}_{{end}}, err = l.request({{.Num}}, constants.Program, buf)
+	{{if .RetStruct}}r{{else}}_{{end}}, err = l.requestStream({{.Num}}, constants.Program, buf,
+    {{- if (ne .WriteStreamIdx -1)}} outStream,{{else}} nil,{{end}}
+    {{- if (ne .ReadStreamIdx -1)}} inStream{{else}} nil{{end -}}
+    )
 	if err != nil {
 		return
 	}
diff --git a/libvirt.gen.go b/libvirt.gen.go
index 698318e..5a29655 100644
--- a/libvirt.gen.go
+++ b/libvirt.gen.go
@@ -23,6 +23,7 @@ package libvirt
 import (
 	"bytes"
 	"fmt"
+	"io"
 
 	"github.com/davecgh/go-xdr/xdr2"
 	"github.com/digitalocean/go-libvirt/internal/constants"
@@ -3952,7 +3953,7 @@ func (l *Libvirt) ConnectOpen(Name OptString, Flags ConnectFlags) (err error) {
 	}
 
 
-	_, err = l.request(1, constants.Program, buf)
+	_, err = l.requestStream(1, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -3965,7 +3966,7 @@ func (l *Libvirt) ConnectClose() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(2, constants.Program, buf)
+	_, err = l.requestStream(2, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -3978,7 +3979,7 @@ func (l *Libvirt) ConnectGetType() (rType string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(3, constants.Program, buf)
+	r, err = l.requestStream(3, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4000,7 +4001,7 @@ func (l *Libvirt) ConnectGetVersion() (rHvVer uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(4, constants.Program, buf)
+	r, err = l.requestStream(4, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4031,7 +4032,7 @@ func (l *Libvirt) ConnectGetMaxVcpus(Type OptString) (rMaxVcpus int32, err error
 	}
 
 	var r response
-	r, err = l.request(5, constants.Program, buf)
+	r, err = l.requestStream(5, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4053,7 +4054,7 @@ func (l *Libvirt) NodeGetInfo() (rModel [32]int8, rMemory uint64, rCpus int32, r
 	var buf []byte
 
 	var r response
-	r, err = l.request(6, constants.Program, buf)
+	r, err = l.requestStream(6, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4110,7 +4111,7 @@ func (l *Libvirt) ConnectGetCapabilities() (rCapabilities string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(7, constants.Program, buf)
+	r, err = l.requestStream(7, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4142,7 +4143,7 @@ func (l *Libvirt) DomainAttachDevice(Dom Domain, XML string) (err error) {
 	}
 
 
-	_, err = l.request(8, constants.Program, buf)
+	_, err = l.requestStream(8, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4164,7 +4165,7 @@ func (l *Libvirt) DomainCreate(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(9, constants.Program, buf)
+	_, err = l.requestStream(9, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4187,7 +4188,7 @@ func (l *Libvirt) DomainCreateXML(XMLDesc string, Flags DomainCreateFlags) (rDom
 	}
 
 	var r response
-	r, err = l.request(10, constants.Program, buf)
+	r, err = l.requestStream(10, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4218,7 +4219,7 @@ func (l *Libvirt) DomainDefineXML(XML string) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(11, constants.Program, buf)
+	r, err = l.requestStream(11, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4249,7 +4250,7 @@ func (l *Libvirt) DomainDestroy(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(12, constants.Program, buf)
+	_, err = l.requestStream(12, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4272,7 +4273,7 @@ func (l *Libvirt) DomainDetachDevice(Dom Domain, XML string) (err error) {
 	}
 
 
-	_, err = l.request(13, constants.Program, buf)
+	_, err = l.requestStream(13, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4295,7 +4296,7 @@ func (l *Libvirt) DomainGetXMLDesc(Dom Domain, Flags DomainXMLFlags) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(14, constants.Program, buf)
+	r, err = l.requestStream(14, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4326,7 +4327,7 @@ func (l *Libvirt) DomainGetAutostart(Dom Domain) (rAutostart int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(15, constants.Program, buf)
+	r, err = l.requestStream(15, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4357,7 +4358,7 @@ func (l *Libvirt) DomainGetInfo(Dom Domain) (rState uint8, rMaxMem uint64, rMemo
 	}
 
 	var r response
-	r, err = l.request(16, constants.Program, buf)
+	r, err = l.requestStream(16, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4408,7 +4409,7 @@ func (l *Libvirt) DomainGetMaxMemory(Dom Domain) (rMemory uint64, err error) {
 	}
 
 	var r response
-	r, err = l.request(17, constants.Program, buf)
+	r, err = l.requestStream(17, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4439,7 +4440,7 @@ func (l *Libvirt) DomainGetMaxVcpus(Dom Domain) (rNum int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(18, constants.Program, buf)
+	r, err = l.requestStream(18, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4470,7 +4471,7 @@ func (l *Libvirt) DomainGetOsType(Dom Domain) (rType string, err error) {
 	}
 
 	var r response
-	r, err = l.request(19, constants.Program, buf)
+	r, err = l.requestStream(19, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4503,7 +4504,7 @@ func (l *Libvirt) DomainGetVcpus(Dom Domain, Maxinfo int32, Maplen int32) (rInfo
 	}
 
 	var r response
-	r, err = l.request(20, constants.Program, buf)
+	r, err = l.requestStream(20, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4539,7 +4540,7 @@ func (l *Libvirt) ConnectListDefinedDomains(Maxnames int32) (rNames []string, er
 	}
 
 	var r response
-	r, err = l.request(21, constants.Program, buf)
+	r, err = l.requestStream(21, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4570,7 +4571,7 @@ func (l *Libvirt) DomainLookupByID(ID int32) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(22, constants.Program, buf)
+	r, err = l.requestStream(22, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4601,7 +4602,7 @@ func (l *Libvirt) DomainLookupByName(Name string) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(23, constants.Program, buf)
+	r, err = l.requestStream(23, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4632,7 +4633,7 @@ func (l *Libvirt) DomainLookupByUUID(UUID UUID) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(24, constants.Program, buf)
+	r, err = l.requestStream(24, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4654,7 +4655,7 @@ func (l *Libvirt) ConnectNumOfDefinedDomains() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(25, constants.Program, buf)
+	r, err = l.requestStream(25, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4687,7 +4688,7 @@ func (l *Libvirt) DomainPinVcpu(Dom Domain, Vcpu uint32, Cpumap []byte) (err err
 	}
 
 
-	_, err = l.request(26, constants.Program, buf)
+	_, err = l.requestStream(26, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4710,7 +4711,7 @@ func (l *Libvirt) DomainReboot(Dom Domain, Flags DomainRebootFlagValues) (err er
 	}
 
 
-	_, err = l.request(27, constants.Program, buf)
+	_, err = l.requestStream(27, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4732,7 +4733,7 @@ func (l *Libvirt) DomainResume(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(28, constants.Program, buf)
+	_, err = l.requestStream(28, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4755,7 +4756,7 @@ func (l *Libvirt) DomainSetAutostart(Dom Domain, Autostart int32) (err error) {
 	}
 
 
-	_, err = l.request(29, constants.Program, buf)
+	_, err = l.requestStream(29, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4778,7 +4779,7 @@ func (l *Libvirt) DomainSetMaxMemory(Dom Domain, Memory uint64) (err error) {
 	}
 
 
-	_, err = l.request(30, constants.Program, buf)
+	_, err = l.requestStream(30, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4801,7 +4802,7 @@ func (l *Libvirt) DomainSetMemory(Dom Domain, Memory uint64) (err error) {
 	}
 
 
-	_, err = l.request(31, constants.Program, buf)
+	_, err = l.requestStream(31, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4824,7 +4825,7 @@ func (l *Libvirt) DomainSetVcpus(Dom Domain, Nvcpus uint32) (err error) {
 	}
 
 
-	_, err = l.request(32, constants.Program, buf)
+	_, err = l.requestStream(32, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4846,7 +4847,7 @@ func (l *Libvirt) DomainShutdown(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(33, constants.Program, buf)
+	_, err = l.requestStream(33, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4868,7 +4869,7 @@ func (l *Libvirt) DomainSuspend(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(34, constants.Program, buf)
+	_, err = l.requestStream(34, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4890,7 +4891,7 @@ func (l *Libvirt) DomainUndefine(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(35, constants.Program, buf)
+	_, err = l.requestStream(35, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4912,7 +4913,7 @@ func (l *Libvirt) ConnectListDefinedNetworks(Maxnames int32) (rNames []string, e
 	}
 
 	var r response
-	r, err = l.request(36, constants.Program, buf)
+	r, err = l.requestStream(36, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4943,7 +4944,7 @@ func (l *Libvirt) ConnectListDomains(Maxids int32) (rIds []int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(37, constants.Program, buf)
+	r, err = l.requestStream(37, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4974,7 +4975,7 @@ func (l *Libvirt) ConnectListNetworks(Maxnames int32) (rNames []string, err erro
 	}
 
 	var r response
-	r, err = l.request(38, constants.Program, buf)
+	r, err = l.requestStream(38, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5005,7 +5006,7 @@ func (l *Libvirt) NetworkCreate(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(39, constants.Program, buf)
+	_, err = l.requestStream(39, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5027,7 +5028,7 @@ func (l *Libvirt) NetworkCreateXML(XML string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(40, constants.Program, buf)
+	r, err = l.requestStream(40, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5058,7 +5059,7 @@ func (l *Libvirt) NetworkDefineXML(XML string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(41, constants.Program, buf)
+	r, err = l.requestStream(41, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5089,7 +5090,7 @@ func (l *Libvirt) NetworkDestroy(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(42, constants.Program, buf)
+	_, err = l.requestStream(42, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5112,7 +5113,7 @@ func (l *Libvirt) NetworkGetXMLDesc(Net Network, Flags uint32) (rXML string, err
 	}
 
 	var r response
-	r, err = l.request(43, constants.Program, buf)
+	r, err = l.requestStream(43, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5143,7 +5144,7 @@ func (l *Libvirt) NetworkGetAutostart(Net Network) (rAutostart int32, err error)
 	}
 
 	var r response
-	r, err = l.request(44, constants.Program, buf)
+	r, err = l.requestStream(44, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5174,7 +5175,7 @@ func (l *Libvirt) NetworkGetBridgeName(Net Network) (rName string, err error) {
 	}
 
 	var r response
-	r, err = l.request(45, constants.Program, buf)
+	r, err = l.requestStream(45, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5205,7 +5206,7 @@ func (l *Libvirt) NetworkLookupByName(Name string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(46, constants.Program, buf)
+	r, err = l.requestStream(46, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5236,7 +5237,7 @@ func (l *Libvirt) NetworkLookupByUUID(UUID UUID) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(47, constants.Program, buf)
+	r, err = l.requestStream(47, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5268,7 +5269,7 @@ func (l *Libvirt) NetworkSetAutostart(Net Network, Autostart int32) (err error)
 	}
 
 
-	_, err = l.request(48, constants.Program, buf)
+	_, err = l.requestStream(48, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5290,7 +5291,7 @@ func (l *Libvirt) NetworkUndefine(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(49, constants.Program, buf)
+	_, err = l.requestStream(49, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5303,7 +5304,7 @@ func (l *Libvirt) ConnectNumOfDefinedNetworks() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(50, constants.Program, buf)
+	r, err = l.requestStream(50, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5325,7 +5326,7 @@ func (l *Libvirt) ConnectNumOfDomains() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(51, constants.Program, buf)
+	r, err = l.requestStream(51, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5347,7 +5348,7 @@ func (l *Libvirt) ConnectNumOfNetworks() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(52, constants.Program, buf)
+	r, err = l.requestStream(52, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5380,7 +5381,7 @@ func (l *Libvirt) DomainCoreDump(Dom Domain, To string, Flags DomainCoreDumpFlag
 	}
 
 
-	_, err = l.request(53, constants.Program, buf)
+	_, err = l.requestStream(53, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5402,7 +5403,7 @@ func (l *Libvirt) DomainRestore(From string) (err error) {
 	}
 
 
-	_, err = l.request(54, constants.Program, buf)
+	_, err = l.requestStream(54, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5425,7 +5426,7 @@ func (l *Libvirt) DomainSave(Dom Domain, To string) (err error) {
 	}
 
 
-	_, err = l.request(55, constants.Program, buf)
+	_, err = l.requestStream(55, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5447,7 +5448,7 @@ func (l *Libvirt) DomainGetSchedulerType(Dom Domain) (rType string, rNparams int
 	}
 
 	var r response
-	r, err = l.request(56, constants.Program, buf)
+	r, err = l.requestStream(56, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5484,7 +5485,7 @@ func (l *Libvirt) DomainGetSchedulerParameters(Dom Domain, Nparams int32) (rPara
 	}
 
 	var r response
-	r, err = l.request(57, constants.Program, buf)
+	r, err = l.requestStream(57, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5517,7 +5518,7 @@ func (l *Libvirt) DomainSetSchedulerParameters(Dom Domain, Params []TypedParam)
 	}
 
 
-	_, err = l.request(58, constants.Program, buf)
+	_, err = l.requestStream(58, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5530,7 +5531,7 @@ func (l *Libvirt) ConnectGetHostname() (rHostname string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(59, constants.Program, buf)
+	r, err = l.requestStream(59, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5561,7 +5562,7 @@ func (l *Libvirt) ConnectSupportsFeature(Feature int32) (rSupported int32, err e
 	}
 
 	var r response
-	r, err = l.request(60, constants.Program, buf)
+	r, err = l.requestStream(60, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5595,7 +5596,7 @@ func (l *Libvirt) DomainMigratePrepare(UriIn OptString, Flags uint64, Dname OptS
 	}
 
 	var r response
-	r, err = l.request(61, constants.Program, buf)
+	r, err = l.requestStream(61, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5636,7 +5637,7 @@ func (l *Libvirt) DomainMigratePerform(Dom Domain, Cookie []byte, Uri string, Fl
 	}
 
 
-	_, err = l.request(62, constants.Program, buf)
+	_, err = l.requestStream(62, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5661,7 +5662,7 @@ func (l *Libvirt) DomainMigrateFinish(Dname string, Cookie []byte, Uri string, F
 	}
 
 	var r response
-	r, err = l.request(63, constants.Program, buf)
+	r, err = l.requestStream(63, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5693,7 +5694,7 @@ func (l *Libvirt) DomainBlockStats(Dom Domain, Path string) (rRdReq int64, rRdBy
 	}
 
 	var r response
-	r, err = l.request(64, constants.Program, buf)
+	r, err = l.requestStream(64, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5745,7 +5746,7 @@ func (l *Libvirt) DomainInterfaceStats(Dom Domain, Device string) (rRxBytes int6
 	}
 
 	var r response
-	r, err = l.request(65, constants.Program, buf)
+	r, err = l.requestStream(65, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5802,7 +5803,7 @@ func (l *Libvirt) AuthList() (rTypes []AuthType, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(66, constants.Program, buf)
+	r, err = l.requestStream(66, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5824,7 +5825,7 @@ func (l *Libvirt) AuthSaslInit() (rMechlist string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(67, constants.Program, buf)
+	r, err = l.requestStream(67, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5857,7 +5858,7 @@ func (l *Libvirt) AuthSaslStart(Mech string, Nil int32, Data []int8) (rComplete
 	}
 
 	var r response
-	r, err = l.request(68, constants.Program, buf)
+	r, err = l.requestStream(68, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5899,7 +5900,7 @@ func (l *Libvirt) AuthSaslStep(Nil int32, Data []int8) (rComplete int32, rNil in
 	}
 
 	var r response
-	r, err = l.request(69, constants.Program, buf)
+	r, err = l.requestStream(69, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5931,7 +5932,7 @@ func (l *Libvirt) AuthPolkit() (rComplete int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(70, constants.Program, buf)
+	r, err = l.requestStream(70, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5953,7 +5954,7 @@ func (l *Libvirt) ConnectNumOfStoragePools() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(71, constants.Program, buf)
+	r, err = l.requestStream(71, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5984,7 +5985,7 @@ func (l *Libvirt) ConnectListStoragePools(Maxnames int32) (rNames []string, err
 	}
 
 	var r response
-	r, err = l.request(72, constants.Program, buf)
+	r, err = l.requestStream(72, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6006,7 +6007,7 @@ func (l *Libvirt) ConnectNumOfDefinedStoragePools() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(73, constants.Program, buf)
+	r, err = l.requestStream(73, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6037,7 +6038,7 @@ func (l *Libvirt) ConnectListDefinedStoragePools(Maxnames int32) (rNames []strin
 	}
 
 	var r response
-	r, err = l.request(74, constants.Program, buf)
+	r, err = l.requestStream(74, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6070,7 +6071,7 @@ func (l *Libvirt) ConnectFindStoragePoolSources(Type string, SrcSpec OptString,
 	}
 
 	var r response
-	r, err = l.request(75, constants.Program, buf)
+	r, err = l.requestStream(75, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6102,7 +6103,7 @@ func (l *Libvirt) StoragePoolCreateXML(XML string, Flags StoragePoolCreateFlags)
 	}
 
 	var r response
-	r, err = l.request(76, constants.Program, buf)
+	r, err = l.requestStream(76, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6134,7 +6135,7 @@ func (l *Libvirt) StoragePoolDefineXML(XML string, Flags uint32) (rPool StorageP
 	}
 
 	var r response
-	r, err = l.request(77, constants.Program, buf)
+	r, err = l.requestStream(77, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6166,7 +6167,7 @@ func (l *Libvirt) StoragePoolCreate(Pool StoragePool, Flags StoragePoolCreateFla
 	}
 
 
-	_, err = l.request(78, constants.Program, buf)
+	_, err = l.requestStream(78, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6189,7 +6190,7 @@ func (l *Libvirt) StoragePoolBuild(Pool StoragePool, Flags StoragePoolBuildFlags
 	}
 
 
-	_, err = l.request(79, constants.Program, buf)
+	_, err = l.requestStream(79, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6211,7 +6212,7 @@ func (l *Libvirt) StoragePoolDestroy(Pool StoragePool) (err error) {
 	}
 
 
-	_, err = l.request(80, constants.Program, buf)
+	_, err = l.requestStream(80, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6234,7 +6235,7 @@ func (l *Libvirt) StoragePoolDelete(Pool StoragePool, Flags StoragePoolDeleteFla
 	}
 
 
-	_, err = l.request(81, constants.Program, buf)
+	_, err = l.requestStream(81, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6256,7 +6257,7 @@ func (l *Libvirt) StoragePoolUndefine(Pool StoragePool) (err error) {
 	}
 
 
-	_, err = l.request(82, constants.Program, buf)
+	_, err = l.requestStream(82, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6279,7 +6280,7 @@ func (l *Libvirt) StoragePoolRefresh(Pool StoragePool, Flags uint32) (err error)
 	}
 
 
-	_, err = l.request(83, constants.Program, buf)
+	_, err = l.requestStream(83, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6301,7 +6302,7 @@ func (l *Libvirt) StoragePoolLookupByName(Name string) (rPool StoragePool, err e
 	}
 
 	var r response
-	r, err = l.request(84, constants.Program, buf)
+	r, err = l.requestStream(84, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6332,7 +6333,7 @@ func (l *Libvirt) StoragePoolLookupByUUID(UUID UUID) (rPool StoragePool, err err
 	}
 
 	var r response
-	r, err = l.request(85, constants.Program, buf)
+	r, err = l.requestStream(85, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6363,7 +6364,7 @@ func (l *Libvirt) StoragePoolLookupByVolume(Vol StorageVol) (rPool StoragePool,
 	}
 
 	var r response
-	r, err = l.request(86, constants.Program, buf)
+	r, err = l.requestStream(86, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6394,7 +6395,7 @@ func (l *Libvirt) StoragePoolGetInfo(Pool StoragePool) (rState uint8, rCapacity
 	}
 
 	var r response
-	r, err = l.request(87, constants.Program, buf)
+	r, err = l.requestStream(87, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6441,7 +6442,7 @@ func (l *Libvirt) StoragePoolGetXMLDesc(Pool StoragePool, Flags StorageXMLFlags)
 	}
 
 	var r response
-	r, err = l.request(88, constants.Program, buf)
+	r, err = l.requestStream(88, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6472,7 +6473,7 @@ func (l *Libvirt) StoragePoolGetAutostart(Pool StoragePool) (rAutostart int32, e
 	}
 
 	var r response
-	r, err = l.request(89, constants.Program, buf)
+	r, err = l.requestStream(89, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6504,7 +6505,7 @@ func (l *Libvirt) StoragePoolSetAutostart(Pool StoragePool, Autostart int32) (er
 	}
 
 
-	_, err = l.request(90, constants.Program, buf)
+	_, err = l.requestStream(90, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6526,7 +6527,7 @@ func (l *Libvirt) StoragePoolNumOfVolumes(Pool StoragePool) (rNum int32, err err
 	}
 
 	var r response
-	r, err = l.request(91, constants.Program, buf)
+	r, err = l.requestStream(91, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6558,7 +6559,7 @@ func (l *Libvirt) StoragePoolListVolumes(Pool StoragePool, Maxnames int32) (rNam
 	}
 
 	var r response
-	r, err = l.request(92, constants.Program, buf)
+	r, err = l.requestStream(92, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6591,7 +6592,7 @@ func (l *Libvirt) StorageVolCreateXML(Pool StoragePool, XML string, Flags Storag
 	}
 
 	var r response
-	r, err = l.request(93, constants.Program, buf)
+	r, err = l.requestStream(93, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6623,7 +6624,7 @@ func (l *Libvirt) StorageVolDelete(Vol StorageVol, Flags StorageVolDeleteFlags)
 	}
 
 
-	_, err = l.request(94, constants.Program, buf)
+	_, err = l.requestStream(94, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6646,7 +6647,7 @@ func (l *Libvirt) StorageVolLookupByName(Pool StoragePool, Name string) (rVol St
 	}
 
 	var r response
-	r, err = l.request(95, constants.Program, buf)
+	r, err = l.requestStream(95, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6677,7 +6678,7 @@ func (l *Libvirt) StorageVolLookupByKey(Key string) (rVol StorageVol, err error)
 	}
 
 	var r response
-	r, err = l.request(96, constants.Program, buf)
+	r, err = l.requestStream(96, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6708,7 +6709,7 @@ func (l *Libvirt) StorageVolLookupByPath(Path string) (rVol StorageVol, err erro
 	}
 
 	var r response
-	r, err = l.request(97, constants.Program, buf)
+	r, err = l.requestStream(97, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6739,7 +6740,7 @@ func (l *Libvirt) StorageVolGetInfo(Vol StorageVol) (rType int8, rCapacity uint6
 	}
 
 	var r response
-	r, err = l.request(98, constants.Program, buf)
+	r, err = l.requestStream(98, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6781,7 +6782,7 @@ func (l *Libvirt) StorageVolGetXMLDesc(Vol StorageVol, Flags uint32) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(99, constants.Program, buf)
+	r, err = l.requestStream(99, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6812,7 +6813,7 @@ func (l *Libvirt) StorageVolGetPath(Vol StorageVol) (rName string, err error) {
 	}
 
 	var r response
-	r, err = l.request(100, constants.Program, buf)
+	r, err = l.requestStream(100, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6844,7 +6845,7 @@ func (l *Libvirt) NodeGetCellsFreeMemory(StartCell int32, Maxcells int32) (rCell
 	}
 
 	var r response
-	r, err = l.request(101, constants.Program, buf)
+	r, err = l.requestStream(101, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6866,7 +6867,7 @@ func (l *Libvirt) NodeGetFreeMemory() (rFreeMem uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(102, constants.Program, buf)
+	r, err = l.requestStream(102, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6901,7 +6902,7 @@ func (l *Libvirt) DomainBlockPeek(Dom Domain, Path string, Offset uint64, Size u
 	}
 
 	var r response
-	r, err = l.request(103, constants.Program, buf)
+	r, err = l.requestStream(103, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6935,7 +6936,7 @@ func (l *Libvirt) DomainMemoryPeek(Dom Domain, Offset uint64, Size uint32, Flags
 	}
 
 	var r response
-	r, err = l.request(104, constants.Program, buf)
+	r, err = l.requestStream(104, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6957,7 +6958,7 @@ func (l *Libvirt) ConnectDomainEventRegister() (rCbRegistered int32, err error)
 	var buf []byte
 
 	var r response
-	r, err = l.request(105, constants.Program, buf)
+	r, err = l.requestStream(105, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6979,7 +6980,7 @@ func (l *Libvirt) ConnectDomainEventDeregister() (rCbRegistered int32, err error
 	var buf []byte
 
 	var r response
-	r, err = l.request(106, constants.Program, buf)
+	r, err = l.requestStream(106, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7001,7 +7002,7 @@ func (l *Libvirt) DomainEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(107, constants.Program, buf)
+	_, err = l.requestStream(107, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7027,7 +7028,7 @@ func (l *Libvirt) DomainMigratePrepare2(UriIn OptString, Flags uint64, Dname Opt
 	}
 
 	var r response
-	r, err = l.request(108, constants.Program, buf)
+	r, err = l.requestStream(108, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7067,7 +7068,7 @@ func (l *Libvirt) DomainMigrateFinish2(Dname string, Cookie []byte, Uri string,
 	}
 
 	var r response
-	r, err = l.request(109, constants.Program, buf)
+	r, err = l.requestStream(109, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7089,7 +7090,7 @@ func (l *Libvirt) ConnectGetUri() (rUri string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(110, constants.Program, buf)
+	r, err = l.requestStream(110, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7121,7 +7122,7 @@ func (l *Libvirt) NodeNumOfDevices(Cap OptString, Flags uint32) (rNum int32, err
 	}
 
 	var r response
-	r, err = l.request(111, constants.Program, buf)
+	r, err = l.requestStream(111, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7154,7 +7155,7 @@ func (l *Libvirt) NodeListDevices(Cap OptString, Maxnames int32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(112, constants.Program, buf)
+	r, err = l.requestStream(112, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7185,7 +7186,7 @@ func (l *Libvirt) NodeDeviceLookupByName(Name string) (rDev NodeDevice, err erro
 	}
 
 	var r response
-	r, err = l.request(113, constants.Program, buf)
+	r, err = l.requestStream(113, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7217,7 +7218,7 @@ func (l *Libvirt) NodeDeviceGetXMLDesc(Name string, Flags uint32) (rXML string,
 	}
 
 	var r response
-	r, err = l.request(114, constants.Program, buf)
+	r, err = l.requestStream(114, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7248,7 +7249,7 @@ func (l *Libvirt) NodeDeviceGetParent(Name string) (rParent OptString, err error
 	}
 
 	var r response
-	r, err = l.request(115, constants.Program, buf)
+	r, err = l.requestStream(115, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7279,7 +7280,7 @@ func (l *Libvirt) NodeDeviceNumOfCaps(Name string) (rNum int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(116, constants.Program, buf)
+	r, err = l.requestStream(116, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7311,7 +7312,7 @@ func (l *Libvirt) NodeDeviceListCaps(Name string, Maxnames int32) (rNames []stri
 	}
 
 	var r response
-	r, err = l.request(117, constants.Program, buf)
+	r, err = l.requestStream(117, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7342,7 +7343,7 @@ func (l *Libvirt) NodeDeviceDettach(Name string) (err error) {
 	}
 
 
-	_, err = l.request(118, constants.Program, buf)
+	_, err = l.requestStream(118, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7364,7 +7365,7 @@ func (l *Libvirt) NodeDeviceReAttach(Name string) (err error) {
 	}
 
 
-	_, err = l.request(119, constants.Program, buf)
+	_, err = l.requestStream(119, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7386,7 +7387,7 @@ func (l *Libvirt) NodeDeviceReset(Name string) (err error) {
 	}
 
 
-	_, err = l.request(120, constants.Program, buf)
+	_, err = l.requestStream(120, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7408,7 +7409,7 @@ func (l *Libvirt) DomainGetSecurityLabel(Dom Domain) (rLabel []int8, rEnforcing
 	}
 
 	var r response
-	r, err = l.request(121, constants.Program, buf)
+	r, err = l.requestStream(121, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7435,7 +7436,7 @@ func (l *Libvirt) NodeGetSecurityModel() (rModel []int8, rDoi []int8, err error)
 	var buf []byte
 
 	var r response
-	r, err = l.request(122, constants.Program, buf)
+	r, err = l.requestStream(122, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7472,7 +7473,7 @@ func (l *Libvirt) NodeDeviceCreateXML(XMLDesc string, Flags uint32) (rDev NodeDe
 	}
 
 	var r response
-	r, err = l.request(123, constants.Program, buf)
+	r, err = l.requestStream(123, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7503,7 +7504,7 @@ func (l *Libvirt) NodeDeviceDestroy(Name string) (err error) {
 	}
 
 
-	_, err = l.request(124, constants.Program, buf)
+	_, err = l.requestStream(124, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7528,7 +7529,7 @@ func (l *Libvirt) StorageVolCreateXMLFrom(Pool StoragePool, XML string, Clonevol
 	}
 
 	var r response
-	r, err = l.request(125, constants.Program, buf)
+	r, err = l.requestStream(125, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7550,7 +7551,7 @@ func (l *Libvirt) ConnectNumOfInterfaces() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(126, constants.Program, buf)
+	r, err = l.requestStream(126, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7581,7 +7582,7 @@ func (l *Libvirt) ConnectListInterfaces(Maxnames int32) (rNames []string, err er
 	}
 
 	var r response
-	r, err = l.request(127, constants.Program, buf)
+	r, err = l.requestStream(127, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7612,7 +7613,7 @@ func (l *Libvirt) InterfaceLookupByName(Name string) (rIface Interface, err erro
 	}
 
 	var r response
-	r, err = l.request(128, constants.Program, buf)
+	r, err = l.requestStream(128, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7643,7 +7644,7 @@ func (l *Libvirt) InterfaceLookupByMacString(Mac string) (rIface Interface, err
 	}
 
 	var r response
-	r, err = l.request(129, constants.Program, buf)
+	r, err = l.requestStream(129, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7675,7 +7676,7 @@ func (l *Libvirt) InterfaceGetXMLDesc(Iface Interface, Flags uint32) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(130, constants.Program, buf)
+	r, err = l.requestStream(130, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7707,7 +7708,7 @@ func (l *Libvirt) InterfaceDefineXML(XML string, Flags uint32) (rIface Interface
 	}
 
 	var r response
-	r, err = l.request(131, constants.Program, buf)
+	r, err = l.requestStream(131, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7738,7 +7739,7 @@ func (l *Libvirt) InterfaceUndefine(Iface Interface) (err error) {
 	}
 
 
-	_, err = l.request(132, constants.Program, buf)
+	_, err = l.requestStream(132, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7761,7 +7762,7 @@ func (l *Libvirt) InterfaceCreate(Iface Interface, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(133, constants.Program, buf)
+	_, err = l.requestStream(133, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7784,7 +7785,7 @@ func (l *Libvirt) InterfaceDestroy(Iface Interface, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(134, constants.Program, buf)
+	_, err = l.requestStream(134, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7808,7 +7809,7 @@ func (l *Libvirt) ConnectDomainXMLFromNative(NativeFormat string, NativeConfig s
 	}
 
 	var r response
-	r, err = l.request(135, constants.Program, buf)
+	r, err = l.requestStream(135, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7841,7 +7842,7 @@ func (l *Libvirt) ConnectDomainXMLToNative(NativeFormat string, DomainXML string
 	}
 
 	var r response
-	r, err = l.request(136, constants.Program, buf)
+	r, err = l.requestStream(136, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7863,7 +7864,7 @@ func (l *Libvirt) ConnectNumOfDefinedInterfaces() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(137, constants.Program, buf)
+	r, err = l.requestStream(137, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7894,7 +7895,7 @@ func (l *Libvirt) ConnectListDefinedInterfaces(Maxnames int32) (rNames []string,
 	}
 
 	var r response
-	r, err = l.request(138, constants.Program, buf)
+	r, err = l.requestStream(138, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7916,7 +7917,7 @@ func (l *Libvirt) ConnectNumOfSecrets() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(139, constants.Program, buf)
+	r, err = l.requestStream(139, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7947,7 +7948,7 @@ func (l *Libvirt) ConnectListSecrets(Maxuuids int32) (rUuids []string, err error
 	}
 
 	var r response
-	r, err = l.request(140, constants.Program, buf)
+	r, err = l.requestStream(140, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7978,7 +7979,7 @@ func (l *Libvirt) SecretLookupByUUID(UUID UUID) (rOptSecret Secret, err error) {
 	}
 
 	var r response
-	r, err = l.request(141, constants.Program, buf)
+	r, err = l.requestStream(141, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8010,7 +8011,7 @@ func (l *Libvirt) SecretDefineXML(XML string, Flags uint32) (rOptSecret Secret,
 	}
 
 	var r response
-	r, err = l.request(142, constants.Program, buf)
+	r, err = l.requestStream(142, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8042,7 +8043,7 @@ func (l *Libvirt) SecretGetXMLDesc(OptSecret Secret, Flags uint32) (rXML string,
 	}
 
 	var r response
-	r, err = l.request(143, constants.Program, buf)
+	r, err = l.requestStream(143, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8075,7 +8076,7 @@ func (l *Libvirt) SecretSetValue(OptSecret Secret, Value []byte, Flags uint32) (
 	}
 
 
-	_, err = l.request(144, constants.Program, buf)
+	_, err = l.requestStream(144, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8098,7 +8099,7 @@ func (l *Libvirt) SecretGetValue(OptSecret Secret, Flags uint32) (rValue []byte,
 	}
 
 	var r response
-	r, err = l.request(145, constants.Program, buf)
+	r, err = l.requestStream(145, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8129,7 +8130,7 @@ func (l *Libvirt) SecretUndefine(OptSecret Secret) (err error) {
 	}
 
 
-	_, err = l.request(146, constants.Program, buf)
+	_, err = l.requestStream(146, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8152,7 +8153,7 @@ func (l *Libvirt) SecretLookupByUsage(UsageType int32, UsageID string) (rOptSecr
 	}
 
 	var r response
-	r, err = l.request(147, constants.Program, buf)
+	r, err = l.requestStream(147, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8170,7 +8171,7 @@ func (l *Libvirt) SecretLookupByUsage(UsageType int32, UsageID string) (rOptSecr
 }
 
 // DomainMigratePrepareTunnel is the go wrapper for REMOTE_PROC_DOMAIN_MIGRATE_PREPARE_TUNNEL.
-func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, Dname OptString, Resource uint64, DomXML string) (err error) {
+func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, outStream io.Reader, Dname OptString, Resource uint64, DomXML string) (err error) {
 	var buf []byte
 
 	args := DomainMigratePrepareTunnelArgs {
@@ -8186,7 +8187,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, Dname OptString, Reso
 	}
 
 
-	_, err = l.request(148, constants.Program, buf)
+	_, err = l.requestStream(148, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -8199,7 +8200,7 @@ func (l *Libvirt) ConnectIsSecure() (rSecure int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(149, constants.Program, buf)
+	r, err = l.requestStream(149, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8230,7 +8231,7 @@ func (l *Libvirt) DomainIsActive(Dom Domain) (rActive int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(150, constants.Program, buf)
+	r, err = l.requestStream(150, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8261,7 +8262,7 @@ func (l *Libvirt) DomainIsPersistent(Dom Domain) (rPersistent int32, err error)
 	}
 
 	var r response
-	r, err = l.request(151, constants.Program, buf)
+	r, err = l.requestStream(151, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8292,7 +8293,7 @@ func (l *Libvirt) NetworkIsActive(Net Network) (rActive int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(152, constants.Program, buf)
+	r, err = l.requestStream(152, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8323,7 +8324,7 @@ func (l *Libvirt) NetworkIsPersistent(Net Network) (rPersistent int32, err error
 	}
 
 	var r response
-	r, err = l.request(153, constants.Program, buf)
+	r, err = l.requestStream(153, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8354,7 +8355,7 @@ func (l *Libvirt) StoragePoolIsActive(Pool StoragePool) (rActive int32, err erro
 	}
 
 	var r response
-	r, err = l.request(154, constants.Program, buf)
+	r, err = l.requestStream(154, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8385,7 +8386,7 @@ func (l *Libvirt) StoragePoolIsPersistent(Pool StoragePool) (rPersistent int32,
 	}
 
 	var r response
-	r, err = l.request(155, constants.Program, buf)
+	r, err = l.requestStream(155, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8416,7 +8417,7 @@ func (l *Libvirt) InterfaceIsActive(Iface Interface) (rActive int32, err error)
 	}
 
 	var r response
-	r, err = l.request(156, constants.Program, buf)
+	r, err = l.requestStream(156, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8438,7 +8439,7 @@ func (l *Libvirt) ConnectGetLibVersion() (rLibVer uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(157, constants.Program, buf)
+	r, err = l.requestStream(157, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8470,7 +8471,7 @@ func (l *Libvirt) ConnectCompareCPU(XML string, Flags ConnectCompareCPUFlags) (r
 	}
 
 	var r response
-	r, err = l.request(158, constants.Program, buf)
+	r, err = l.requestStream(158, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8503,7 +8504,7 @@ func (l *Libvirt) DomainMemoryStats(Dom Domain, MaxStats uint32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(159, constants.Program, buf)
+	r, err = l.requestStream(159, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8536,7 +8537,7 @@ func (l *Libvirt) DomainAttachDeviceFlags(Dom Domain, XML string, Flags uint32)
 	}
 
 
-	_, err = l.request(160, constants.Program, buf)
+	_, err = l.requestStream(160, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8560,7 +8561,7 @@ func (l *Libvirt) DomainDetachDeviceFlags(Dom Domain, XML string, Flags uint32)
 	}
 
 
-	_, err = l.request(161, constants.Program, buf)
+	_, err = l.requestStream(161, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8583,7 +8584,7 @@ func (l *Libvirt) ConnectBaselineCPU(XMLCPUs []string, Flags ConnectBaselineCPUF
 	}
 
 	var r response
-	r, err = l.request(162, constants.Program, buf)
+	r, err = l.requestStream(162, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8614,7 +8615,7 @@ func (l *Libvirt) DomainGetJobInfo(Dom Domain) (rType int32, rTimeElapsed uint64
 	}
 
 	var r response
-	r, err = l.request(163, constants.Program, buf)
+	r, err = l.requestStream(163, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8700,7 +8701,7 @@ func (l *Libvirt) DomainAbortJob(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(164, constants.Program, buf)
+	_, err = l.requestStream(164, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8723,7 +8724,7 @@ func (l *Libvirt) StorageVolWipe(Vol StorageVol, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(165, constants.Program, buf)
+	_, err = l.requestStream(165, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8747,7 +8748,7 @@ func (l *Libvirt) DomainMigrateSetMaxDowntime(Dom Domain, Downtime uint64, Flags
 	}
 
 
-	_, err = l.request(166, constants.Program, buf)
+	_, err = l.requestStream(166, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8769,7 +8770,7 @@ func (l *Libvirt) ConnectDomainEventRegisterAny(EventID int32) (err error) {
 	}
 
 
-	_, err = l.request(167, constants.Program, buf)
+	_, err = l.requestStream(167, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8791,7 +8792,7 @@ func (l *Libvirt) ConnectDomainEventDeregisterAny(EventID int32) (err error) {
 	}
 
 
-	_, err = l.request(168, constants.Program, buf)
+	_, err = l.requestStream(168, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8804,7 +8805,7 @@ func (l *Libvirt) DomainEventReboot() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(169, constants.Program, buf)
+	_, err = l.requestStream(169, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8817,7 +8818,7 @@ func (l *Libvirt) DomainEventRtcChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(170, constants.Program, buf)
+	_, err = l.requestStream(170, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8830,7 +8831,7 @@ func (l *Libvirt) DomainEventWatchdog() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(171, constants.Program, buf)
+	_, err = l.requestStream(171, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8843,7 +8844,7 @@ func (l *Libvirt) DomainEventIOError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(172, constants.Program, buf)
+	_, err = l.requestStream(172, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8856,7 +8857,7 @@ func (l *Libvirt) DomainEventGraphics() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(173, constants.Program, buf)
+	_, err = l.requestStream(173, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8880,7 +8881,7 @@ func (l *Libvirt) DomainUpdateDeviceFlags(Dom Domain, XML string, Flags DomainDe
 	}
 
 
-	_, err = l.request(174, constants.Program, buf)
+	_, err = l.requestStream(174, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8902,7 +8903,7 @@ func (l *Libvirt) NwfilterLookupByName(Name string) (rOptNwfilter Nwfilter, err
 	}
 
 	var r response
-	r, err = l.request(175, constants.Program, buf)
+	r, err = l.requestStream(175, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8933,7 +8934,7 @@ func (l *Libvirt) NwfilterLookupByUUID(UUID UUID) (rOptNwfilter Nwfilter, err er
 	}
 
 	var r response
-	r, err = l.request(176, constants.Program, buf)
+	r, err = l.requestStream(176, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8965,7 +8966,7 @@ func (l *Libvirt) NwfilterGetXMLDesc(OptNwfilter Nwfilter, Flags uint32) (rXML s
 	}
 
 	var r response
-	r, err = l.request(177, constants.Program, buf)
+	r, err = l.requestStream(177, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8987,7 +8988,7 @@ func (l *Libvirt) ConnectNumOfNwfilters() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(178, constants.Program, buf)
+	r, err = l.requestStream(178, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9018,7 +9019,7 @@ func (l *Libvirt) ConnectListNwfilters(Maxnames int32) (rNames []string, err err
 	}
 
 	var r response
-	r, err = l.request(179, constants.Program, buf)
+	r, err = l.requestStream(179, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9049,7 +9050,7 @@ func (l *Libvirt) NwfilterDefineXML(XML string) (rOptNwfilter Nwfilter, err erro
 	}
 
 	var r response
-	r, err = l.request(180, constants.Program, buf)
+	r, err = l.requestStream(180, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9080,7 +9081,7 @@ func (l *Libvirt) NwfilterUndefine(OptNwfilter Nwfilter) (err error) {
 	}
 
 
-	_, err = l.request(181, constants.Program, buf)
+	_, err = l.requestStream(181, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9103,7 +9104,7 @@ func (l *Libvirt) DomainManagedSave(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(182, constants.Program, buf)
+	_, err = l.requestStream(182, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9126,7 +9127,7 @@ func (l *Libvirt) DomainHasManagedSaveImage(Dom Domain, Flags uint32) (rResult i
 	}
 
 	var r response
-	r, err = l.request(183, constants.Program, buf)
+	r, err = l.requestStream(183, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9158,7 +9159,7 @@ func (l *Libvirt) DomainManagedSaveRemove(Dom Domain, Flags uint32) (err error)
 	}
 
 
-	_, err = l.request(184, constants.Program, buf)
+	_, err = l.requestStream(184, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9182,7 +9183,7 @@ func (l *Libvirt) DomainSnapshotCreateXML(Dom Domain, XMLDesc string, Flags uint
 	}
 
 	var r response
-	r, err = l.request(185, constants.Program, buf)
+	r, err = l.requestStream(185, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9214,7 +9215,7 @@ func (l *Libvirt) DomainSnapshotGetXMLDesc(Snap DomainSnapshot, Flags uint32) (r
 	}
 
 	var r response
-	r, err = l.request(186, constants.Program, buf)
+	r, err = l.requestStream(186, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9246,7 +9247,7 @@ func (l *Libvirt) DomainSnapshotNum(Dom Domain, Flags uint32) (rNum int32, err e
 	}
 
 	var r response
-	r, err = l.request(187, constants.Program, buf)
+	r, err = l.requestStream(187, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9279,7 +9280,7 @@ func (l *Libvirt) DomainSnapshotListNames(Dom Domain, Maxnames int32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(188, constants.Program, buf)
+	r, err = l.requestStream(188, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9312,7 +9313,7 @@ func (l *Libvirt) DomainSnapshotLookupByName(Dom Domain, Name string, Flags uint
 	}
 
 	var r response
-	r, err = l.request(189, constants.Program, buf)
+	r, err = l.requestStream(189, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9344,7 +9345,7 @@ func (l *Libvirt) DomainHasCurrentSnapshot(Dom Domain, Flags uint32) (rResult in
 	}
 
 	var r response
-	r, err = l.request(190, constants.Program, buf)
+	r, err = l.requestStream(190, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9376,7 +9377,7 @@ func (l *Libvirt) DomainSnapshotCurrent(Dom Domain, Flags uint32) (rSnap DomainS
 	}
 
 	var r response
-	r, err = l.request(191, constants.Program, buf)
+	r, err = l.requestStream(191, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9408,7 +9409,7 @@ func (l *Libvirt) DomainRevertToSnapshot(Snap DomainSnapshot, Flags uint32) (err
 	}
 
 
-	_, err = l.request(192, constants.Program, buf)
+	_, err = l.requestStream(192, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9431,7 +9432,7 @@ func (l *Libvirt) DomainSnapshotDelete(Snap DomainSnapshot, Flags DomainSnapshot
 	}
 
 
-	_, err = l.request(193, constants.Program, buf)
+	_, err = l.requestStream(193, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9455,7 +9456,7 @@ func (l *Libvirt) DomainGetBlockInfo(Dom Domain, Path string, Flags uint32) (rAl
 	}
 
 	var r response
-	r, err = l.request(194, constants.Program, buf)
+	r, err = l.requestStream(194, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9487,7 +9488,7 @@ func (l *Libvirt) DomainEventIOErrorReason() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(195, constants.Program, buf)
+	_, err = l.requestStream(195, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9510,7 +9511,7 @@ func (l *Libvirt) DomainCreateWithFlags(Dom Domain, Flags uint32) (rDom Domain,
 	}
 
 	var r response
-	r, err = l.request(196, constants.Program, buf)
+	r, err = l.requestStream(196, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9543,7 +9544,7 @@ func (l *Libvirt) DomainSetMemoryParameters(Dom Domain, Params []TypedParam, Fla
 	}
 
 
-	_, err = l.request(197, constants.Program, buf)
+	_, err = l.requestStream(197, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9567,7 +9568,7 @@ func (l *Libvirt) DomainGetMemoryParameters(Dom Domain, Nparams int32, Flags uin
 	}
 
 	var r response
-	r, err = l.request(198, constants.Program, buf)
+	r, err = l.requestStream(198, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9606,7 +9607,7 @@ func (l *Libvirt) DomainSetVcpusFlags(Dom Domain, Nvcpus uint32, Flags uint32) (
 	}
 
 
-	_, err = l.request(199, constants.Program, buf)
+	_, err = l.requestStream(199, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9629,7 +9630,7 @@ func (l *Libvirt) DomainGetVcpusFlags(Dom Domain, Flags uint32) (rNum int32, err
 	}
 
 	var r response
-	r, err = l.request(200, constants.Program, buf)
+	r, err = l.requestStream(200, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9647,7 +9648,7 @@ func (l *Libvirt) DomainGetVcpusFlags(Dom Domain, Flags uint32) (rNum int32, err
 }
 
 // DomainOpenConsole is the go wrapper for REMOTE_PROC_DOMAIN_OPEN_CONSOLE.
-func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, Flags uint32) (err error) {
+func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, inStream io.Writer, Flags uint32) (err error) {
 	var buf []byte
 
 	args := DomainOpenConsoleArgs {
@@ -9662,7 +9663,7 @@ func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, Flags uint32)
 	}
 
 
-	_, err = l.request(201, constants.Program, buf)
+	_, err = l.requestStream(201, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9684,7 +9685,7 @@ func (l *Libvirt) DomainIsUpdated(Dom Domain) (rUpdated int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(202, constants.Program, buf)
+	r, err = l.requestStream(202, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9715,7 +9716,7 @@ func (l *Libvirt) ConnectGetSysinfo(Flags uint32) (rSysinfo string, err error) {
 	}
 
 	var r response
-	r, err = l.request(203, constants.Program, buf)
+	r, err = l.requestStream(203, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9748,7 +9749,7 @@ func (l *Libvirt) DomainSetMemoryFlags(Dom Domain, Memory uint64, Flags uint32)
 	}
 
 
-	_, err = l.request(204, constants.Program, buf)
+	_, err = l.requestStream(204, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9772,7 +9773,7 @@ func (l *Libvirt) DomainSetBlkioParameters(Dom Domain, Params []TypedParam, Flag
 	}
 
 
-	_, err = l.request(205, constants.Program, buf)
+	_, err = l.requestStream(205, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9796,7 +9797,7 @@ func (l *Libvirt) DomainGetBlkioParameters(Dom Domain, Nparams int32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(206, constants.Program, buf)
+	r, err = l.requestStream(206, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9835,7 +9836,7 @@ func (l *Libvirt) DomainMigrateSetMaxSpeed(Dom Domain, Bandwidth uint64, Flags u
 	}
 
 
-	_, err = l.request(207, constants.Program, buf)
+	_, err = l.requestStream(207, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9844,7 +9845,7 @@ func (l *Libvirt) DomainMigrateSetMaxSpeed(Dom Domain, Bandwidth uint64, Flags u
 }
 
 // StorageVolUpload is the go wrapper for REMOTE_PROC_STORAGE_VOL_UPLOAD.
-func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64, Flags uint32) (err error) {
+func (l *Libvirt) StorageVolUpload(Vol StorageVol, outStream io.Reader, Offset uint64, Length uint64, Flags uint32) (err error) {
 	var buf []byte
 
 	args := StorageVolUploadArgs {
@@ -9860,7 +9861,7 @@ func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64,
 	}
 
 
-	_, err = l.request(208, constants.Program, buf)
+	_, err = l.requestStream(208, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -9869,7 +9870,7 @@ func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64,
 }
 
 // StorageVolDownload is the go wrapper for REMOTE_PROC_STORAGE_VOL_DOWNLOAD.
-func (l *Libvirt) StorageVolDownload(Vol StorageVol, Offset uint64, Length uint64, Flags uint32) (err error) {
+func (l *Libvirt) StorageVolDownload(Vol StorageVol, inStream io.Writer, Offset uint64, Length uint64, Flags uint32) (err error) {
 	var buf []byte
 
 	args := StorageVolDownloadArgs {
@@ -9885,7 +9886,7 @@ func (l *Libvirt) StorageVolDownload(Vol StorageVol, Offset uint64, Length uint6
 	}
 
 
-	_, err = l.request(209, constants.Program, buf)
+	_, err = l.requestStream(209, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9908,7 +9909,7 @@ func (l *Libvirt) DomainInjectNmi(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(210, constants.Program, buf)
+	_, err = l.requestStream(210, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9917,7 +9918,7 @@ func (l *Libvirt) DomainInjectNmi(Dom Domain, Flags uint32) (err error) {
 }
 
 // DomainScreenshot is the go wrapper for REMOTE_PROC_DOMAIN_SCREENSHOT.
-func (l *Libvirt) DomainScreenshot(Dom Domain, Screen uint32, Flags uint32) (rMime OptString, err error) {
+func (l *Libvirt) DomainScreenshot(Dom Domain, inStream io.Writer, Screen uint32, Flags uint32) (rMime OptString, err error) {
 	var buf []byte
 
 	args := DomainScreenshotArgs {
@@ -9932,7 +9933,7 @@ func (l *Libvirt) DomainScreenshot(Dom Domain, Screen uint32, Flags uint32) (rMi
 	}
 
 	var r response
-	r, err = l.request(211, constants.Program, buf)
+	r, err = l.requestStream(211, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9964,7 +9965,7 @@ func (l *Libvirt) DomainGetState(Dom Domain, Flags uint32) (rState int32, rReaso
 	}
 
 	var r response
-	r, err = l.request(212, constants.Program, buf)
+	r, err = l.requestStream(212, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10004,7 +10005,7 @@ func (l *Libvirt) DomainMigrateBegin3(Dom Domain, Xmlin OptString, Flags uint64,
 	}
 
 	var r response
-	r, err = l.request(213, constants.Program, buf)
+	r, err = l.requestStream(213, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10045,7 +10046,7 @@ func (l *Libvirt) DomainMigratePrepare3(CookieIn []byte, UriIn OptString, Flags
 	}
 
 	var r response
-	r, err = l.request(214, constants.Program, buf)
+	r, err = l.requestStream(214, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10068,7 +10069,7 @@ func (l *Libvirt) DomainMigratePrepare3(CookieIn []byte, UriIn OptString, Flags
 }
 
 // DomainMigratePrepareTunnel3 is the go wrapper for REMOTE_PROC_DOMAIN_MIGRATE_PREPARE_TUNNEL3.
-func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, Flags uint64, Dname OptString, Resource uint64, DomXML string) (rCookieOut []byte, err error) {
+func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, outStream io.Reader, Flags uint64, Dname OptString, Resource uint64, DomXML string) (rCookieOut []byte, err error) {
 	var buf []byte
 
 	args := DomainMigratePrepareTunnel3Args {
@@ -10085,7 +10086,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, Flags uint64, Dna
 	}
 
 	var r response
-	r, err = l.request(215, constants.Program, buf)
+	r, err = l.requestStream(215, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -10123,7 +10124,7 @@ func (l *Libvirt) DomainMigratePerform3(Dom Domain, Xmlin OptString, CookieIn []
 	}
 
 	var r response
-	r, err = l.request(216, constants.Program, buf)
+	r, err = l.requestStream(216, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10159,7 +10160,7 @@ func (l *Libvirt) DomainMigrateFinish3(Dname string, CookieIn []byte, Dconnuri O
 	}
 
 	var r response
-	r, err = l.request(217, constants.Program, buf)
+	r, err = l.requestStream(217, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10198,7 +10199,7 @@ func (l *Libvirt) DomainMigrateConfirm3(Dom Domain, CookieIn []byte, Flags uint6
 	}
 
 
-	_, err = l.request(218, constants.Program, buf)
+	_, err = l.requestStream(218, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10222,7 +10223,7 @@ func (l *Libvirt) DomainSetSchedulerParametersFlags(Dom Domain, Params []TypedPa
 	}
 
 
-	_, err = l.request(219, constants.Program, buf)
+	_, err = l.requestStream(219, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10244,7 +10245,7 @@ func (l *Libvirt) InterfaceChangeBegin(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(220, constants.Program, buf)
+	_, err = l.requestStream(220, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10266,7 +10267,7 @@ func (l *Libvirt) InterfaceChangeCommit(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(221, constants.Program, buf)
+	_, err = l.requestStream(221, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10288,7 +10289,7 @@ func (l *Libvirt) InterfaceChangeRollback(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(222, constants.Program, buf)
+	_, err = l.requestStream(222, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10312,7 +10313,7 @@ func (l *Libvirt) DomainGetSchedulerParametersFlags(Dom Domain, Nparams int32, F
 	}
 
 	var r response
-	r, err = l.request(223, constants.Program, buf)
+	r, err = l.requestStream(223, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10335,7 +10336,7 @@ func (l *Libvirt) DomainEventControlError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(224, constants.Program, buf)
+	_, err = l.requestStream(224, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10360,7 +10361,7 @@ func (l *Libvirt) DomainPinVcpuFlags(Dom Domain, Vcpu uint32, Cpumap []byte, Fla
 	}
 
 
-	_, err = l.request(225, constants.Program, buf)
+	_, err = l.requestStream(225, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10386,7 +10387,7 @@ func (l *Libvirt) DomainSendKey(Dom Domain, Codeset uint32, Holdtime uint32, Key
 	}
 
 
-	_, err = l.request(226, constants.Program, buf)
+	_, err = l.requestStream(226, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10410,7 +10411,7 @@ func (l *Libvirt) NodeGetCPUStats(CPUNum int32, Nparams int32, Flags uint32) (rP
 	}
 
 	var r response
-	r, err = l.request(227, constants.Program, buf)
+	r, err = l.requestStream(227, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10448,7 +10449,7 @@ func (l *Libvirt) NodeGetMemoryStats(Nparams int32, CellNum int32, Flags uint32)
 	}
 
 	var r response
-	r, err = l.request(228, constants.Program, buf)
+	r, err = l.requestStream(228, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10485,7 +10486,7 @@ func (l *Libvirt) DomainGetControlInfo(Dom Domain, Flags uint32) (rState uint32,
 	}
 
 	var r response
-	r, err = l.request(229, constants.Program, buf)
+	r, err = l.requestStream(229, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10529,7 +10530,7 @@ func (l *Libvirt) DomainGetVcpuPinInfo(Dom Domain, Ncpumaps int32, Maplen int32,
 	}
 
 	var r response
-	r, err = l.request(230, constants.Program, buf)
+	r, err = l.requestStream(230, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10566,7 +10567,7 @@ func (l *Libvirt) DomainUndefineFlags(Dom Domain, Flags DomainUndefineFlagsValue
 	}
 
 
-	_, err = l.request(231, constants.Program, buf)
+	_, err = l.requestStream(231, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10591,7 +10592,7 @@ func (l *Libvirt) DomainSaveFlags(Dom Domain, To string, Dxml OptString, Flags u
 	}
 
 
-	_, err = l.request(232, constants.Program, buf)
+	_, err = l.requestStream(232, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10615,7 +10616,7 @@ func (l *Libvirt) DomainRestoreFlags(From string, Dxml OptString, Flags uint32)
 	}
 
 
-	_, err = l.request(233, constants.Program, buf)
+	_, err = l.requestStream(233, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10638,7 +10639,7 @@ func (l *Libvirt) DomainDestroyFlags(Dom Domain, Flags DomainDestroyFlagsValues)
 	}
 
 
-	_, err = l.request(234, constants.Program, buf)
+	_, err = l.requestStream(234, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10661,7 +10662,7 @@ func (l *Libvirt) DomainSaveImageGetXMLDesc(File string, Flags uint32) (rXML str
 	}
 
 	var r response
-	r, err = l.request(235, constants.Program, buf)
+	r, err = l.requestStream(235, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10694,7 +10695,7 @@ func (l *Libvirt) DomainSaveImageDefineXML(File string, Dxml string, Flags uint3
 	}
 
 
-	_, err = l.request(236, constants.Program, buf)
+	_, err = l.requestStream(236, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10718,7 +10719,7 @@ func (l *Libvirt) DomainBlockJobAbort(Dom Domain, Path string, Flags DomainBlock
 	}
 
 
-	_, err = l.request(237, constants.Program, buf)
+	_, err = l.requestStream(237, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10742,7 +10743,7 @@ func (l *Libvirt) DomainGetBlockJobInfo(Dom Domain, Path string, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(238, constants.Program, buf)
+	r, err = l.requestStream(238, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10796,7 +10797,7 @@ func (l *Libvirt) DomainBlockJobSetSpeed(Dom Domain, Path string, Bandwidth uint
 	}
 
 
-	_, err = l.request(239, constants.Program, buf)
+	_, err = l.requestStream(239, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10821,7 +10822,7 @@ func (l *Libvirt) DomainBlockPull(Dom Domain, Path string, Bandwidth uint64, Fla
 	}
 
 
-	_, err = l.request(240, constants.Program, buf)
+	_, err = l.requestStream(240, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10834,7 +10835,7 @@ func (l *Libvirt) DomainEventBlockJob() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(241, constants.Program, buf)
+	_, err = l.requestStream(241, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10857,7 +10858,7 @@ func (l *Libvirt) DomainMigrateGetMaxSpeed(Dom Domain, Flags uint32) (rBandwidth
 	}
 
 	var r response
-	r, err = l.request(242, constants.Program, buf)
+	r, err = l.requestStream(242, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10891,7 +10892,7 @@ func (l *Libvirt) DomainBlockStatsFlags(Dom Domain, Path string, Nparams int32,
 	}
 
 	var r response
-	r, err = l.request(243, constants.Program, buf)
+	r, err = l.requestStream(243, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10929,7 +10930,7 @@ func (l *Libvirt) DomainSnapshotGetParent(Snap DomainSnapshot, Flags uint32) (rS
 	}
 
 	var r response
-	r, err = l.request(244, constants.Program, buf)
+	r, err = l.requestStream(244, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10961,7 +10962,7 @@ func (l *Libvirt) DomainReset(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(245, constants.Program, buf)
+	_, err = l.requestStream(245, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10984,7 +10985,7 @@ func (l *Libvirt) DomainSnapshotNumChildren(Snap DomainSnapshot, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(246, constants.Program, buf)
+	r, err = l.requestStream(246, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11017,7 +11018,7 @@ func (l *Libvirt) DomainSnapshotListChildrenNames(Snap DomainSnapshot, Maxnames
 	}
 
 	var r response
-	r, err = l.request(247, constants.Program, buf)
+	r, err = l.requestStream(247, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11039,7 +11040,7 @@ func (l *Libvirt) DomainEventDiskChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(248, constants.Program, buf)
+	_, err = l.requestStream(248, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11063,7 +11064,7 @@ func (l *Libvirt) DomainOpenGraphics(Dom Domain, Idx uint32, Flags DomainOpenGra
 	}
 
 
-	_, err = l.request(249, constants.Program, buf)
+	_, err = l.requestStream(249, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11087,7 +11088,7 @@ func (l *Libvirt) NodeSuspendForDuration(Target uint32, Duration uint64, Flags u
 	}
 
 
-	_, err = l.request(250, constants.Program, buf)
+	_, err = l.requestStream(250, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11112,7 +11113,7 @@ func (l *Libvirt) DomainBlockResize(Dom Domain, Disk string, Size uint64, Flags
 	}
 
 
-	_, err = l.request(251, constants.Program, buf)
+	_, err = l.requestStream(251, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11137,7 +11138,7 @@ func (l *Libvirt) DomainSetBlockIOTune(Dom Domain, Disk string, Params []TypedPa
 	}
 
 
-	_, err = l.request(252, constants.Program, buf)
+	_, err = l.requestStream(252, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11162,7 +11163,7 @@ func (l *Libvirt) DomainGetBlockIOTune(Dom Domain, Disk OptString, Nparams int32
 	}
 
 	var r response
-	r, err = l.request(253, constants.Program, buf)
+	r, err = l.requestStream(253, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11201,7 +11202,7 @@ func (l *Libvirt) DomainSetNumaParameters(Dom Domain, Params []TypedParam, Flags
 	}
 
 
-	_, err = l.request(254, constants.Program, buf)
+	_, err = l.requestStream(254, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11225,7 +11226,7 @@ func (l *Libvirt) DomainGetNumaParameters(Dom Domain, Nparams int32, Flags uint3
 	}
 
 	var r response
-	r, err = l.request(255, constants.Program, buf)
+	r, err = l.requestStream(255, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11265,7 +11266,7 @@ func (l *Libvirt) DomainSetInterfaceParameters(Dom Domain, Device string, Params
 	}
 
 
-	_, err = l.request(256, constants.Program, buf)
+	_, err = l.requestStream(256, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11290,7 +11291,7 @@ func (l *Libvirt) DomainGetInterfaceParameters(Dom Domain, Device string, Nparam
 	}
 
 	var r response
-	r, err = l.request(257, constants.Program, buf)
+	r, err = l.requestStream(257, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11328,7 +11329,7 @@ func (l *Libvirt) DomainShutdownFlags(Dom Domain, Flags DomainShutdownFlagValues
 	}
 
 
-	_, err = l.request(258, constants.Program, buf)
+	_, err = l.requestStream(258, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11352,7 +11353,7 @@ func (l *Libvirt) StorageVolWipePattern(Vol StorageVol, Algorithm uint32, Flags
 	}
 
 
-	_, err = l.request(259, constants.Program, buf)
+	_, err = l.requestStream(259, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11376,7 +11377,7 @@ func (l *Libvirt) StorageVolResize(Vol StorageVol, Capacity uint64, Flags Storag
 	}
 
 
-	_, err = l.request(260, constants.Program, buf)
+	_, err = l.requestStream(260, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11401,7 +11402,7 @@ func (l *Libvirt) DomainPmSuspendForDuration(Dom Domain, Target uint32, Duration
 	}
 
 
-	_, err = l.request(261, constants.Program, buf)
+	_, err = l.requestStream(261, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11427,7 +11428,7 @@ func (l *Libvirt) DomainGetCPUStats(Dom Domain, Nparams uint32, StartCPU int32,
 	}
 
 	var r response
-	r, err = l.request(262, constants.Program, buf)
+	r, err = l.requestStream(262, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11466,7 +11467,7 @@ func (l *Libvirt) DomainGetDiskErrors(Dom Domain, Maxerrors uint32, Flags uint32
 	}
 
 	var r response
-	r, err = l.request(263, constants.Program, buf)
+	r, err = l.requestStream(263, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11507,7 +11508,7 @@ func (l *Libvirt) DomainSetMetadata(Dom Domain, Type int32, Metadata OptString,
 	}
 
 
-	_, err = l.request(264, constants.Program, buf)
+	_, err = l.requestStream(264, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11532,7 +11533,7 @@ func (l *Libvirt) DomainGetMetadata(Dom Domain, Type int32, Uri OptString, Flags
 	}
 
 	var r response
-	r, err = l.request(265, constants.Program, buf)
+	r, err = l.requestStream(265, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11567,7 +11568,7 @@ func (l *Libvirt) DomainBlockRebase(Dom Domain, Path string, Base OptString, Ban
 	}
 
 
-	_, err = l.request(266, constants.Program, buf)
+	_, err = l.requestStream(266, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11590,7 +11591,7 @@ func (l *Libvirt) DomainPmWakeup(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(267, constants.Program, buf)
+	_, err = l.requestStream(267, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11603,7 +11604,7 @@ func (l *Libvirt) DomainEventTrayChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(268, constants.Program, buf)
+	_, err = l.requestStream(268, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11616,7 +11617,7 @@ func (l *Libvirt) DomainEventPmwakeup() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(269, constants.Program, buf)
+	_, err = l.requestStream(269, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11629,7 +11630,7 @@ func (l *Libvirt) DomainEventPmsuspend() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(270, constants.Program, buf)
+	_, err = l.requestStream(270, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11652,7 +11653,7 @@ func (l *Libvirt) DomainSnapshotIsCurrent(Snap DomainSnapshot, Flags uint32) (rC
 	}
 
 	var r response
-	r, err = l.request(271, constants.Program, buf)
+	r, err = l.requestStream(271, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11684,7 +11685,7 @@ func (l *Libvirt) DomainSnapshotHasMetadata(Snap DomainSnapshot, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(272, constants.Program, buf)
+	r, err = l.requestStream(272, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11716,7 +11717,7 @@ func (l *Libvirt) ConnectListAllDomains(NeedResults int32, Flags ConnectListAllD
 	}
 
 	var r response
-	r, err = l.request(273, constants.Program, buf)
+	r, err = l.requestStream(273, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11754,7 +11755,7 @@ func (l *Libvirt) DomainListAllSnapshots(Dom Domain, NeedResults int32, Flags ui
 	}
 
 	var r response
-	r, err = l.request(274, constants.Program, buf)
+	r, err = l.requestStream(274, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11792,7 +11793,7 @@ func (l *Libvirt) DomainSnapshotListAllChildren(Snapshot DomainSnapshot, NeedRes
 	}
 
 	var r response
-	r, err = l.request(275, constants.Program, buf)
+	r, err = l.requestStream(275, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11819,7 +11820,7 @@ func (l *Libvirt) DomainEventBalloonChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(276, constants.Program, buf)
+	_, err = l.requestStream(276, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11842,7 +11843,7 @@ func (l *Libvirt) DomainGetHostname(Dom Domain, Flags uint32) (rHostname string,
 	}
 
 	var r response
-	r, err = l.request(277, constants.Program, buf)
+	r, err = l.requestStream(277, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11873,7 +11874,7 @@ func (l *Libvirt) DomainGetSecurityLabelList(Dom Domain) (rLabels []DomainGetSec
 	}
 
 	var r response
-	r, err = l.request(278, constants.Program, buf)
+	r, err = l.requestStream(278, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11911,7 +11912,7 @@ func (l *Libvirt) DomainPinEmulator(Dom Domain, Cpumap []byte, Flags DomainModif
 	}
 
 
-	_, err = l.request(279, constants.Program, buf)
+	_, err = l.requestStream(279, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11935,7 +11936,7 @@ func (l *Libvirt) DomainGetEmulatorPinInfo(Dom Domain, Maplen int32, Flags Domai
 	}
 
 	var r response
-	r, err = l.request(280, constants.Program, buf)
+	r, err = l.requestStream(280, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11972,7 +11973,7 @@ func (l *Libvirt) ConnectListAllStoragePools(NeedResults int32, Flags ConnectLis
 	}
 
 	var r response
-	r, err = l.request(281, constants.Program, buf)
+	r, err = l.requestStream(281, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12010,7 +12011,7 @@ func (l *Libvirt) StoragePoolListAllVolumes(Pool StoragePool, NeedResults int32,
 	}
 
 	var r response
-	r, err = l.request(282, constants.Program, buf)
+	r, err = l.requestStream(282, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12047,7 +12048,7 @@ func (l *Libvirt) ConnectListAllNetworks(NeedResults int32, Flags ConnectListAll
 	}
 
 	var r response
-	r, err = l.request(283, constants.Program, buf)
+	r, err = l.requestStream(283, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12084,7 +12085,7 @@ func (l *Libvirt) ConnectListAllInterfaces(NeedResults int32, Flags ConnectListA
 	}
 
 	var r response
-	r, err = l.request(284, constants.Program, buf)
+	r, err = l.requestStream(284, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12121,7 +12122,7 @@ func (l *Libvirt) ConnectListAllNodeDevices(NeedResults int32, Flags uint32) (rD
 	}
 
 	var r response
-	r, err = l.request(285, constants.Program, buf)
+	r, err = l.requestStream(285, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12158,7 +12159,7 @@ func (l *Libvirt) ConnectListAllNwfilters(NeedResults int32, Flags uint32) (rFil
 	}
 
 	var r response
-	r, err = l.request(286, constants.Program, buf)
+	r, err = l.requestStream(286, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12195,7 +12196,7 @@ func (l *Libvirt) ConnectListAllSecrets(NeedResults int32, Flags ConnectListAllS
 	}
 
 	var r response
-	r, err = l.request(287, constants.Program, buf)
+	r, err = l.requestStream(287, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12232,7 +12233,7 @@ func (l *Libvirt) NodeSetMemoryParameters(Params []TypedParam, Flags uint32) (er
 	}
 
 
-	_, err = l.request(288, constants.Program, buf)
+	_, err = l.requestStream(288, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12255,7 +12256,7 @@ func (l *Libvirt) NodeGetMemoryParameters(Nparams int32, Flags uint32) (rParams
 	}
 
 	var r response
-	r, err = l.request(289, constants.Program, buf)
+	r, err = l.requestStream(289, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12297,7 +12298,7 @@ func (l *Libvirt) DomainBlockCommit(Dom Domain, Disk string, Base OptString, Top
 	}
 
 
-	_, err = l.request(290, constants.Program, buf)
+	_, err = l.requestStream(290, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12324,7 +12325,7 @@ func (l *Libvirt) NetworkUpdate(Net Network, Command uint32, Section uint32, Par
 	}
 
 
-	_, err = l.request(291, constants.Program, buf)
+	_, err = l.requestStream(291, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12337,7 +12338,7 @@ func (l *Libvirt) DomainEventPmsuspendDisk() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(292, constants.Program, buf)
+	_, err = l.requestStream(292, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12361,7 +12362,7 @@ func (l *Libvirt) NodeGetCPUMap(NeedMap int32, NeedOnline int32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(293, constants.Program, buf)
+	r, err = l.requestStream(293, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12405,7 +12406,7 @@ func (l *Libvirt) DomainFstrim(Dom Domain, MountPoint OptString, Minimum uint64,
 	}
 
 
-	_, err = l.request(294, constants.Program, buf)
+	_, err = l.requestStream(294, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12430,7 +12431,7 @@ func (l *Libvirt) DomainSendProcessSignal(Dom Domain, PidValue int64, Signum uin
 	}
 
 
-	_, err = l.request(295, constants.Program, buf)
+	_, err = l.requestStream(295, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12439,7 +12440,7 @@ func (l *Libvirt) DomainSendProcessSignal(Dom Domain, PidValue int64, Signum uin
 }
 
 // DomainOpenChannel is the go wrapper for REMOTE_PROC_DOMAIN_OPEN_CHANNEL.
-func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, Flags DomainChannelFlags) (err error) {
+func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, inStream io.Writer, Flags DomainChannelFlags) (err error) {
 	var buf []byte
 
 	args := DomainOpenChannelArgs {
@@ -12454,7 +12455,7 @@ func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, Flags DomainChan
 	}
 
 
-	_, err = l.request(296, constants.Program, buf)
+	_, err = l.requestStream(296, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -12478,7 +12479,7 @@ func (l *Libvirt) NodeDeviceLookupScsiHostByWwn(Wwnn string, Wwpn string, Flags
 	}
 
 	var r response
-	r, err = l.request(297, constants.Program, buf)
+	r, err = l.requestStream(297, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12510,7 +12511,7 @@ func (l *Libvirt) DomainGetJobStats(Dom Domain, Flags DomainGetJobStatsFlags) (r
 	}
 
 	var r response
-	r, err = l.request(298, constants.Program, buf)
+	r, err = l.requestStream(298, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12548,7 +12549,7 @@ func (l *Libvirt) DomainMigrateGetCompressionCache(Dom Domain, Flags uint32) (rC
 	}
 
 	var r response
-	r, err = l.request(299, constants.Program, buf)
+	r, err = l.requestStream(299, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12581,7 +12582,7 @@ func (l *Libvirt) DomainMigrateSetCompressionCache(Dom Domain, CacheSize uint64,
 	}
 
 
-	_, err = l.request(300, constants.Program, buf)
+	_, err = l.requestStream(300, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12605,7 +12606,7 @@ func (l *Libvirt) NodeDeviceDetachFlags(Name string, DriverName OptString, Flags
 	}
 
 
-	_, err = l.request(301, constants.Program, buf)
+	_, err = l.requestStream(301, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12629,7 +12630,7 @@ func (l *Libvirt) DomainMigrateBegin3Params(Dom Domain, Params []TypedParam, Fla
 	}
 
 	var r response
-	r, err = l.request(302, constants.Program, buf)
+	r, err = l.requestStream(302, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12667,7 +12668,7 @@ func (l *Libvirt) DomainMigratePrepare3Params(Params []TypedParam, CookieIn []by
 	}
 
 	var r response
-	r, err = l.request(303, constants.Program, buf)
+	r, err = l.requestStream(303, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12705,7 +12706,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel3Params(Params []TypedParam, CookieI
 	}
 
 	var r response
-	r, err = l.request(304, constants.Program, buf)
+	r, err = l.requestStream(304, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12740,7 +12741,7 @@ func (l *Libvirt) DomainMigratePerform3Params(Dom Domain, Dconnuri OptString, Pa
 	}
 
 	var r response
-	r, err = l.request(305, constants.Program, buf)
+	r, err = l.requestStream(305, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12774,7 +12775,7 @@ func (l *Libvirt) DomainMigrateFinish3Params(Params []TypedParam, CookieIn []byt
 	}
 
 	var r response
-	r, err = l.request(306, constants.Program, buf)
+	r, err = l.requestStream(306, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12814,7 +12815,7 @@ func (l *Libvirt) DomainMigrateConfirm3Params(Dom Domain, Params []TypedParam, C
 	}
 
 
-	_, err = l.request(307, constants.Program, buf)
+	_, err = l.requestStream(307, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12838,7 +12839,7 @@ func (l *Libvirt) DomainSetMemoryStatsPeriod(Dom Domain, Period int32, Flags Dom
 	}
 
 
-	_, err = l.request(308, constants.Program, buf)
+	_, err = l.requestStream(308, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12861,7 +12862,7 @@ func (l *Libvirt) DomainCreateXMLWithFiles(XMLDesc string, Flags DomainCreateFla
 	}
 
 	var r response
-	r, err = l.request(309, constants.Program, buf)
+	r, err = l.requestStream(309, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12893,7 +12894,7 @@ func (l *Libvirt) DomainCreateWithFiles(Dom Domain, Flags DomainCreateFlags) (rD
 	}
 
 	var r response
-	r, err = l.request(310, constants.Program, buf)
+	r, err = l.requestStream(310, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12915,7 +12916,7 @@ func (l *Libvirt) DomainEventDeviceRemoved() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(311, constants.Program, buf)
+	_, err = l.requestStream(311, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12939,7 +12940,7 @@ func (l *Libvirt) ConnectGetCPUModelNames(Arch string, NeedResults int32, Flags
 	}
 
 	var r response
-	r, err = l.request(312, constants.Program, buf)
+	r, err = l.requestStream(312, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12976,7 +12977,7 @@ func (l *Libvirt) ConnectNetworkEventRegisterAny(EventID int32, Net OptNetwork)
 	}
 
 	var r response
-	r, err = l.request(313, constants.Program, buf)
+	r, err = l.requestStream(313, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13007,7 +13008,7 @@ func (l *Libvirt) ConnectNetworkEventDeregisterAny(CallbackID int32) (err error)
 	}
 
 
-	_, err = l.request(314, constants.Program, buf)
+	_, err = l.requestStream(314, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13020,7 +13021,7 @@ func (l *Libvirt) NetworkEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(315, constants.Program, buf)
+	_, err = l.requestStream(315, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13043,7 +13044,7 @@ func (l *Libvirt) ConnectDomainEventCallbackRegisterAny(EventID int32, Dom OptDo
 	}
 
 	var r response
-	r, err = l.request(316, constants.Program, buf)
+	r, err = l.requestStream(316, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13074,7 +13075,7 @@ func (l *Libvirt) ConnectDomainEventCallbackDeregisterAny(CallbackID int32) (err
 	}
 
 
-	_, err = l.request(317, constants.Program, buf)
+	_, err = l.requestStream(317, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13087,7 +13088,7 @@ func (l *Libvirt) DomainEventCallbackLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(318, constants.Program, buf)
+	_, err = l.requestStream(318, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13100,7 +13101,7 @@ func (l *Libvirt) DomainEventCallbackReboot() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(319, constants.Program, buf)
+	_, err = l.requestStream(319, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13113,7 +13114,7 @@ func (l *Libvirt) DomainEventCallbackRtcChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(320, constants.Program, buf)
+	_, err = l.requestStream(320, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13126,7 +13127,7 @@ func (l *Libvirt) DomainEventCallbackWatchdog() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(321, constants.Program, buf)
+	_, err = l.requestStream(321, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13139,7 +13140,7 @@ func (l *Libvirt) DomainEventCallbackIOError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(322, constants.Program, buf)
+	_, err = l.requestStream(322, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13152,7 +13153,7 @@ func (l *Libvirt) DomainEventCallbackGraphics() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(323, constants.Program, buf)
+	_, err = l.requestStream(323, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13165,7 +13166,7 @@ func (l *Libvirt) DomainEventCallbackIOErrorReason() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(324, constants.Program, buf)
+	_, err = l.requestStream(324, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13178,7 +13179,7 @@ func (l *Libvirt) DomainEventCallbackControlError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(325, constants.Program, buf)
+	_, err = l.requestStream(325, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13191,7 +13192,7 @@ func (l *Libvirt) DomainEventCallbackBlockJob() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(326, constants.Program, buf)
+	_, err = l.requestStream(326, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13204,7 +13205,7 @@ func (l *Libvirt) DomainEventCallbackDiskChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(327, constants.Program, buf)
+	_, err = l.requestStream(327, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13217,7 +13218,7 @@ func (l *Libvirt) DomainEventCallbackTrayChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(328, constants.Program, buf)
+	_, err = l.requestStream(328, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13230,7 +13231,7 @@ func (l *Libvirt) DomainEventCallbackPmwakeup() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(329, constants.Program, buf)
+	_, err = l.requestStream(329, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13243,7 +13244,7 @@ func (l *Libvirt) DomainEventCallbackPmsuspend() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(330, constants.Program, buf)
+	_, err = l.requestStream(330, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13256,7 +13257,7 @@ func (l *Libvirt) DomainEventCallbackBalloonChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(331, constants.Program, buf)
+	_, err = l.requestStream(331, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13269,7 +13270,7 @@ func (l *Libvirt) DomainEventCallbackPmsuspendDisk() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(332, constants.Program, buf)
+	_, err = l.requestStream(332, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13282,7 +13283,7 @@ func (l *Libvirt) DomainEventCallbackDeviceRemoved() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(333, constants.Program, buf)
+	_, err = l.requestStream(333, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13307,7 +13308,7 @@ func (l *Libvirt) DomainCoreDumpWithFormat(Dom Domain, To string, Dumpformat uin
 	}
 
 
-	_, err = l.request(334, constants.Program, buf)
+	_, err = l.requestStream(334, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13331,7 +13332,7 @@ func (l *Libvirt) DomainFsfreeze(Dom Domain, Mountpoints []string, Flags uint32)
 	}
 
 	var r response
-	r, err = l.request(335, constants.Program, buf)
+	r, err = l.requestStream(335, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13364,7 +13365,7 @@ func (l *Libvirt) DomainFsthaw(Dom Domain, Mountpoints []string, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(336, constants.Program, buf)
+	r, err = l.requestStream(336, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13396,7 +13397,7 @@ func (l *Libvirt) DomainGetTime(Dom Domain, Flags uint32) (rSeconds int64, rNsec
 	}
 
 	var r response
-	r, err = l.request(337, constants.Program, buf)
+	r, err = l.requestStream(337, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13435,7 +13436,7 @@ func (l *Libvirt) DomainSetTime(Dom Domain, Seconds int64, Nseconds uint32, Flag
 	}
 
 
-	_, err = l.request(338, constants.Program, buf)
+	_, err = l.requestStream(338, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13448,7 +13449,7 @@ func (l *Libvirt) DomainEventBlockJob2() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(339, constants.Program, buf)
+	_, err = l.requestStream(339, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13473,7 +13474,7 @@ func (l *Libvirt) NodeGetFreePages(Pages []uint32, StartCell int32, CellCount ui
 	}
 
 	var r response
-	r, err = l.request(340, constants.Program, buf)
+	r, err = l.requestStream(340, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13507,7 +13508,7 @@ func (l *Libvirt) NetworkGetDhcpLeases(Net Network, Mac OptString, NeedResults i
 	}
 
 	var r response
-	r, err = l.request(341, constants.Program, buf)
+	r, err = l.requestStream(341, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13547,7 +13548,7 @@ func (l *Libvirt) ConnectGetDomainCapabilities(Emulatorbin OptString, Arch OptSt
 	}
 
 	var r response
-	r, err = l.request(342, constants.Program, buf)
+	r, err = l.requestStream(342, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13580,7 +13581,7 @@ func (l *Libvirt) DomainOpenGraphicsFd(Dom Domain, Idx uint32, Flags DomainOpenG
 	}
 
 
-	_, err = l.request(343, constants.Program, buf)
+	_, err = l.requestStream(343, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13604,7 +13605,7 @@ func (l *Libvirt) ConnectGetAllDomainStats(Doms []Domain, Stats uint32, Flags Co
 	}
 
 	var r response
-	r, err = l.request(344, constants.Program, buf)
+	r, err = l.requestStream(344, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13639,7 +13640,7 @@ func (l *Libvirt) DomainBlockCopy(Dom Domain, Path string, Destxml string, Param
 	}
 
 
-	_, err = l.request(345, constants.Program, buf)
+	_, err = l.requestStream(345, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13652,7 +13653,7 @@ func (l *Libvirt) DomainEventCallbackTunable() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(346, constants.Program, buf)
+	_, err = l.requestStream(346, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13678,7 +13679,7 @@ func (l *Libvirt) NodeAllocPages(PageSizes []uint32, PageCounts []uint64, StartC
 	}
 
 	var r response
-	r, err = l.request(347, constants.Program, buf)
+	r, err = l.requestStream(347, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13700,7 +13701,7 @@ func (l *Libvirt) DomainEventCallbackAgentLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(348, constants.Program, buf)
+	_, err = l.requestStream(348, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13723,7 +13724,7 @@ func (l *Libvirt) DomainGetFsinfo(Dom Domain, Flags uint32) (rInfo []DomainFsinf
 	}
 
 	var r response
-	r, err = l.request(349, constants.Program, buf)
+	r, err = l.requestStream(349, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13760,7 +13761,7 @@ func (l *Libvirt) DomainDefineXMLFlags(XML string, Flags DomainDefineFlags) (rDo
 	}
 
 	var r response
-	r, err = l.request(350, constants.Program, buf)
+	r, err = l.requestStream(350, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13792,7 +13793,7 @@ func (l *Libvirt) DomainGetIothreadInfo(Dom Domain, Flags DomainModificationImpa
 	}
 
 	var r response
-	r, err = l.request(351, constants.Program, buf)
+	r, err = l.requestStream(351, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13831,7 +13832,7 @@ func (l *Libvirt) DomainPinIothread(Dom Domain, IothreadsID uint32, Cpumap []byt
 	}
 
 
-	_, err = l.request(352, constants.Program, buf)
+	_, err = l.requestStream(352, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13855,7 +13856,7 @@ func (l *Libvirt) DomainInterfaceAddresses(Dom Domain, Source uint32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(353, constants.Program, buf)
+	r, err = l.requestStream(353, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13877,7 +13878,7 @@ func (l *Libvirt) DomainEventCallbackDeviceAdded() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(354, constants.Program, buf)
+	_, err = l.requestStream(354, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13901,7 +13902,7 @@ func (l *Libvirt) DomainAddIothread(Dom Domain, IothreadID uint32, Flags DomainM
 	}
 
 
-	_, err = l.request(355, constants.Program, buf)
+	_, err = l.requestStream(355, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13925,7 +13926,7 @@ func (l *Libvirt) DomainDelIothread(Dom Domain, IothreadID uint32, Flags DomainM
 	}
 
 
-	_, err = l.request(356, constants.Program, buf)
+	_, err = l.requestStream(356, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13950,7 +13951,7 @@ func (l *Libvirt) DomainSetUserPassword(Dom Domain, User OptString, Password Opt
 	}
 
 
-	_, err = l.request(357, constants.Program, buf)
+	_, err = l.requestStream(357, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13974,7 +13975,7 @@ func (l *Libvirt) DomainRename(Dom Domain, NewName OptString, Flags uint32) (rRe
 	}
 
 	var r response
-	r, err = l.request(358, constants.Program, buf)
+	r, err = l.requestStream(358, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13996,7 +13997,7 @@ func (l *Libvirt) DomainEventCallbackMigrationIteration() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(359, constants.Program, buf)
+	_, err = l.requestStream(359, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14009,7 +14010,7 @@ func (l *Libvirt) ConnectRegisterCloseCallback() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(360, constants.Program, buf)
+	_, err = l.requestStream(360, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14022,7 +14023,7 @@ func (l *Libvirt) ConnectUnregisterCloseCallback() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(361, constants.Program, buf)
+	_, err = l.requestStream(361, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14035,7 +14036,7 @@ func (l *Libvirt) ConnectEventConnectionClosed() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(362, constants.Program, buf)
+	_, err = l.requestStream(362, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14048,7 +14049,7 @@ func (l *Libvirt) DomainEventCallbackJobCompleted() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(363, constants.Program, buf)
+	_, err = l.requestStream(363, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14071,7 +14072,7 @@ func (l *Libvirt) DomainMigrateStartPostCopy(Dom Domain, Flags uint32) (err erro
 	}
 
 
-	_, err = l.request(364, constants.Program, buf)
+	_, err = l.requestStream(364, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14094,7 +14095,7 @@ func (l *Libvirt) DomainGetPerfEvents(Dom Domain, Flags DomainModificationImpact
 	}
 
 	var r response
-	r, err = l.request(365, constants.Program, buf)
+	r, err = l.requestStream(365, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14128,7 +14129,7 @@ func (l *Libvirt) DomainSetPerfEvents(Dom Domain, Params []TypedParam, Flags Dom
 	}
 
 
-	_, err = l.request(366, constants.Program, buf)
+	_, err = l.requestStream(366, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14141,7 +14142,7 @@ func (l *Libvirt) DomainEventCallbackDeviceRemovalFailed() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(367, constants.Program, buf)
+	_, err = l.requestStream(367, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14164,7 +14165,7 @@ func (l *Libvirt) ConnectStoragePoolEventRegisterAny(EventID int32, Pool OptStor
 	}
 
 	var r response
-	r, err = l.request(368, constants.Program, buf)
+	r, err = l.requestStream(368, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14195,7 +14196,7 @@ func (l *Libvirt) ConnectStoragePoolEventDeregisterAny(CallbackID int32) (err er
 	}
 
 
-	_, err = l.request(369, constants.Program, buf)
+	_, err = l.requestStream(369, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14208,7 +14209,7 @@ func (l *Libvirt) StoragePoolEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(370, constants.Program, buf)
+	_, err = l.requestStream(370, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14231,7 +14232,7 @@ func (l *Libvirt) DomainGetGuestVcpus(Dom Domain, Flags uint32) (rParams []Typed
 	}
 
 	var r response
-	r, err = l.request(371, constants.Program, buf)
+	r, err = l.requestStream(371, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14266,7 +14267,7 @@ func (l *Libvirt) DomainSetGuestVcpus(Dom Domain, Cpumap string, State int32, Fl
 	}
 
 
-	_, err = l.request(372, constants.Program, buf)
+	_, err = l.requestStream(372, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14279,7 +14280,7 @@ func (l *Libvirt) StoragePoolEventRefresh() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(373, constants.Program, buf)
+	_, err = l.requestStream(373, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14302,7 +14303,7 @@ func (l *Libvirt) ConnectNodeDeviceEventRegisterAny(EventID int32, Dev OptNodeDe
 	}
 
 	var r response
-	r, err = l.request(374, constants.Program, buf)
+	r, err = l.requestStream(374, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14333,7 +14334,7 @@ func (l *Libvirt) ConnectNodeDeviceEventDeregisterAny(CallbackID int32) (err err
 	}
 
 
-	_, err = l.request(375, constants.Program, buf)
+	_, err = l.requestStream(375, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14346,7 +14347,7 @@ func (l *Libvirt) NodeDeviceEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(376, constants.Program, buf)
+	_, err = l.requestStream(376, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14359,7 +14360,7 @@ func (l *Libvirt) NodeDeviceEventUpdate() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(377, constants.Program, buf)
+	_, err = l.requestStream(377, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14382,7 +14383,7 @@ func (l *Libvirt) StorageVolGetInfoFlags(Vol StorageVol, Flags uint32) (rType in
 	}
 
 	var r response
-	r, err = l.request(378, constants.Program, buf)
+	r, err = l.requestStream(378, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14414,7 +14415,7 @@ func (l *Libvirt) DomainEventCallbackMetadataChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(379, constants.Program, buf)
+	_, err = l.requestStream(379, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14437,7 +14438,7 @@ func (l *Libvirt) ConnectSecretEventRegisterAny(EventID int32, OptSecret OptSecr
 	}
 
 	var r response
-	r, err = l.request(380, constants.Program, buf)
+	r, err = l.requestStream(380, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14468,7 +14469,7 @@ func (l *Libvirt) ConnectSecretEventDeregisterAny(CallbackID int32) (err error)
 	}
 
 
-	_, err = l.request(381, constants.Program, buf)
+	_, err = l.requestStream(381, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14481,7 +14482,7 @@ func (l *Libvirt) SecretEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(382, constants.Program, buf)
+	_, err = l.requestStream(382, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14494,7 +14495,7 @@ func (l *Libvirt) SecretEventValueChanged() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(383, constants.Program, buf)
+	_, err = l.requestStream(383, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14519,7 +14520,7 @@ func (l *Libvirt) DomainSetVcpu(Dom Domain, Cpumap string, State int32, Flags Do
 	}
 
 
-	_, err = l.request(384, constants.Program, buf)
+	_, err = l.requestStream(384, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14532,7 +14533,7 @@ func (l *Libvirt) DomainEventBlockThreshold() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(385, constants.Program, buf)
+	_, err = l.requestStream(385, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14557,7 +14558,7 @@ func (l *Libvirt) DomainSetBlockThreshold(Dom Domain, Dev string, Threshold uint
 	}
 
 
-	_, err = l.request(386, constants.Program, buf)
+	_, err = l.requestStream(386, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14580,7 +14581,7 @@ func (l *Libvirt) DomainMigrateGetMaxDowntime(Dom Domain, Flags uint32) (rDownti
 	}
 
 	var r response
-	r, err = l.request(387, constants.Program, buf)
+	r, err = l.requestStream(387, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14612,7 +14613,7 @@ func (l *Libvirt) DomainManagedSaveGetXMLDesc(Dom Domain, Flags DomainXMLFlags)
 	}
 
 	var r response
-	r, err = l.request(388, constants.Program, buf)
+	r, err = l.requestStream(388, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14645,7 +14646,7 @@ func (l *Libvirt) DomainManagedSaveDefineXML(Dom Domain, Dxml OptString, Flags D
 	}
 
 
-	_, err = l.request(389, constants.Program, buf)
+	_, err = l.requestStream(389, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14670,7 +14671,7 @@ func (l *Libvirt) DomainSetLifecycleAction(Dom Domain, Type uint32, Action uint3
 	}
 
 
-	_, err = l.request(390, constants.Program, buf)
+	_, err = l.requestStream(390, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}