144 const Version =
"1.1";
147 const VersionString = sprintf(
"Qore-DataStreamClient/%s", DataStreamClient::Version);
150 const DefaultHeaders = ...;
175 constructor(*hash<auto> opts, *softbool do_not_connect) ;
208 recvDataStream(code rcb, code ecb,
string method,
string path,
auto body, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
240 recvDataStream(
DataStreamRecvMessage dsm,
string method,
string path,
auto body, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
278 hash<auto> sendDataStream(code scb,
string method,
string path, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
316 hash<auto> sendDataStream(
DataStreamSendMessage dsm,
string method,
string path, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
356 sendRecvDataStream(code scb, code rcb, code ecb,
string method,
string path, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
394 sendRecvDataStream(
DataStreamMessage dsm,
string method,
string path, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
426 hash<auto> sendRawStream(code scb,
string method, *
string path, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
465 hash<auto> getRawStream(code rcb,
string method, *
string path,
auto body, timeout timeout_ms = 0, *reference<hash<auto>> info, *hash<auto> hdr);
481 addDefaultHeaders(hash<auto> h);
494 setContentEncoding(
string enc =
'auto');
499 nothing prepareMsg(
string method,
string path, reference<auto> body, reference<hash<auto>> hdr,
string ct =
'Content-Type');
504 hash<auto> sendAndDecodeResponse(*data body,
string m,
string path, hash<auto> hdr, *reference<hash<auto>> info, *softbool decode_errors);
this class can be used to send and receive data using the DataStream protocol
Definition: DataStreamClient.qm.dox.h:79
nothing recvData(auto data)
receives decoded data from the remote end and calls recvDataImpl()
nothing recvDataDoneImpl(*string err)
this method is called when all data has been received
nothing recvDataDone(*string err)
this method is called when all data has been received; this method calls recvDataDoneImpl() ...
the DataStreamClient namespace contains all the public objects in the DataStreamClient module ...
Definition: DataStreamClient.qm.dox.h:77
this class can be used to send and receive data using the DataStream protocol
Definition: DataStreamClient.qm.dox.h:99
abstract nothing recvDataImpl(auto data)
reimplement this method in subclasses to receive decoded and deserialized data
auto sendData()
this method returns data to be returned to the server; when this method returns no value...
this class can be used to send and receive data using the DataStream protocol
Definition: DataStreamClient.qm.dox.h:134
abstract auto sendDataImpl()
reimplement this method in subclasses to support streamed data transfers; when this method returns no...