Make.ReaderResponse-body readers for object consume callbacks.
type 'a io = 'a iotype t = response_body_readerScoped response body reader.
Readers passed to object consume callbacks are valid only until the callback returns. Drain, copy, or decode the body inside that callback.
val read :
t ->
bytes ->
off:int ->
len:int ->
(int, Awskit.Error.t) Stdlib.result ioRead up to len bytes into bytes starting at off.
Returns Ok 0 at end of body.
val next :
?chunk_size:int ->
t ->
(bytes option, Awskit.Error.t) Stdlib.result ioRead the next fresh chunk, or None at end of body.
chunk_size must be positive when supplied.
val fold :
?chunk_size:int ->
t ->
init:'a ->
f:('a -> bytes -> ('a, Awskit.Error.t) Stdlib.result io) ->
('a, Awskit.Error.t) Stdlib.result ioFold over response-body chunks until end of body or the callback returns an error.
val iter :
?chunk_size:int ->
t ->
f:(bytes -> (unit, Awskit.Error.t) Stdlib.result io) ->
(unit, Awskit.Error.t) Stdlib.result ioIterate over response-body chunks until end of body or the callback returns an error.
val to_bytes :
?chunk_size:int ->
max_bytes:int64 ->
t ->
(bytes, Awskit.Error.t) Stdlib.result ioDrain the body into memory as bytes, failing if it exceeds max_bytes.
val to_string :
?chunk_size:int ->
max_bytes:int64 ->
t ->
(string, Awskit.Error.t) Stdlib.result ioDrain the body into a string, failing if it exceeds max_bytes.