This module implements HTTP/1.1 chunked-encoded stream reading and writing.
Types
ChunkedStreamError = object of AsyncStreamError
- Source Edit
ChunkedStreamIncompleteError = object of ChunkedStreamError
- Source Edit
ChunkedStreamProtocolError = object of ChunkedStreamError
- Source Edit
ChunkedStreamReader = ref object of AsyncStreamReader
- Source Edit
ChunkedStreamWriter = ref object of AsyncStreamWriter
- Source Edit
Procs
proc init(child: ChunkedStreamReader; rsource: AsyncStreamReader; bufferSize = ChunkBufferSize) {....raises: [], tags: [], forbids: [].}
- Source Edit
proc init(child: ChunkedStreamWriter; wsource: AsyncStreamWriter; queueSize = AsyncStreamDefaultQueueSize) {....raises: [], tags: [], forbids: [].}
- Source Edit
proc init[T](child: ChunkedStreamReader; rsource: AsyncStreamReader; bufferSize = ChunkBufferSize; udata: ref T) {. ...deprecated: "`udata` deprecated, use inheritance instead", raises: [].}
- Source Edit
proc init[T](child: ChunkedStreamWriter; wsource: AsyncStreamWriter; queueSize = AsyncStreamDefaultQueueSize; udata: ref T) {. ...deprecated: "`udata` deprecated, use inheritance instead", raises: [].}
- Source Edit
proc newChunkedStreamReader(rsource: AsyncStreamReader; bufferSize = AsyncStreamDefaultBufferSize): ChunkedStreamReader {. ...raises: [], tags: [], forbids: [].}
- Source Edit
proc newChunkedStreamReader[T](rsource: AsyncStreamReader; bufferSize = AsyncStreamDefaultBufferSize; udata: ref T): ChunkedStreamReader {. ...deprecated: "`udata` deprecated, use inheritance instead", raises: [].}
- Source Edit
proc newChunkedStreamWriter(wsource: AsyncStreamWriter; queueSize = AsyncStreamDefaultQueueSize): ChunkedStreamWriter {. ...raises: [], tags: [], forbids: [].}
- Source Edit
proc newChunkedStreamWriter[T](wsource: AsyncStreamWriter; queueSize = AsyncStreamDefaultQueueSize; udata: ref T): ChunkedStreamWriter {. ...deprecated: "`udata` deprecated, use inheritance instead", raises: [].}
- Source Edit
Exports
-
NestedPoll, closeSocket, ENOSR, EHOSTUNREACH, EHOSTDOWN, ECONNRESET, EDQUOT, fail, ECANCELED, EMLINK, milliseconds, asyncTimer, +=, $, Second, internalRaiseIfError, getSrcLocation, FutureError, fromNow, weeks, ESPIPE, withTimeout, LocationKind, id, <=, FutureBase, FutureCompletedError, ENOEXEC, ESHUTDOWN, fail, EREMOTEIO, Day, waitFor, complete, internalInitFutureBase, EPROTONOSUPPORT, cancelAndWait, addTimer, Moment, ECOMM, EPROTOTYPE, AsyncExceptionError, FuturePendingError, milliseconds, ENOENT, millis, removeTimer, or, FutureFlag, ENOTCONN, EBUSY, init, ENOTUNIQ, <=, days, +=, race, ==, cancelSoon, AsyncTimeoutError, setThreadDispatcher, EEXIST, ENOLINK, newInternalRaisesFuture, idleAsync, internalRaiseIfError, SomeIntegerI64, ENOMEM, ENOKEY, +, removeWriter2, ENOMSG, EKEYEXPIRED, Week, cancelSoon, awaitne, EAFNOSUPPORT, EWOULDBLOCK, [], EREMOTE, finished, AsyncCallback, EHWPOISON, epochSeconds, newDispatcher, EPERM, microseconds, internalFail, weeks, Finished, ENOTSOCK, cancelCallback=, ETOOMANYREFS, $, EISCONN, callSoon, ESOCKTNOSUPPORT, setGlobalDispatcher, EXDEV, EBADF, EKEYREVOKED, allFinished, TrackerBase, hours, InternalAsyncCallback, EBFONT, ENETDOWN, EACCES, ELOOP, InfiniteDuration, ETIMEDOUT, EINVAL, value, EBADFD, Future, completed, PDispatcher, ESRCH, EL2NSYNC, Finished, low, await, ESTRPIPE, -=, EALREADY, getAsyncTimestamp, EXFULL, Hour, EIDRM, removeReader2, secs, getThreadDispatcher, futureContinue, isZero, ENOANO, EADV, CallbackFunc, contains, cancelAndWait, $, ENFILE, waitFor, high, Microsecond, ENOPKG, ELIBBAD, EOWNERDEAD, handle, ERANGE, done, ENONET, completed, callSoon, toString, cancelSoon, EMSGSIZE, EBADMSG, EILSEQ, ENOPROTOOPT, EDESTADDRREQ, allFutures, -, complete, FutureState, EBADR, nanos, location, FutureDefect, EDOTDOT, one, EKEYREJECTED, <, race, error, one, CancelledError, nanoseconds, EISDIR, sleepAsync, Nanosecond, EOVERFLOW, FutureSeq, cancelAndWait, micros, -, ESRMNT, ENOTEMPTY, EPROTO, TimerCallback, microseconds, error, epochNanoSeconds, ENOTRECOVERABLE, wait, EDOM, value, hours, AsyncError, EBADRQC, ENODEV, FutureStr, addTimer, ENOBUFS, ECHRNG, ENOTDIR, EUNATCH, cancelAndSchedule, failed, nanoseconds, ERESTART, *, ETXTBSY, newFutureStr, EMFILE, LocFinishIndex, withTimeout, addTimer, race, EUSERS, ENOTBLK, Minute, DispatcherHandle, EISNAM, ELIBACC, ENAVAIL, init, race, EUCLEAN, ENOTTY, +, cancelSoon, completed, minutes, cancel, FutureFlags, getGlobalDispatcher, ELIBEXEC, stepsAsync, micros, wait, cancelAndWait, EINPROGRESS, EPFNOSUPPORT, E2BIG, -=, ENOMEDIUM, secs, read, waitFor, EL3HLT, unregisterAndCloseFd, EBADSLT, InternalRaisesFuture, -, <, ENETRESET, fastEpochTime, ENXIO, join, EPIPE, ThreadCallbackFunc, allFutures, race, wait, now, read, asyncSpawn, removeCallback, EAGAIN, raiseOsDefect, EADDRNOTAVAIL, read, removeCallback, TrackerCounter, async, addCallback, init, async, ZeroDuration, EREMCHG, EFAULT, addCallback, seconds, noCancel, low, AsyncFD, ECHILD, Raising, init, ECONNABORTED, state, wait, removeTimer, LocCreateIndex, addReader2, ETIME, ENOLCK, EBADE, EDEADLK, asyncCheck, Duration, ELNRNG, ENOCSI, millis, EMEDIUMTYPE, readError, sleepAsync, isInfinite, callback=, ENETUNREACH, InternalFutureBase, ENOSPC, ENOSYS, ELIBSCN, EIO, EROFS, seconds, ELIBMAX, SrcLoc, ==, ==, div, init, EL2HLT, EOPNOTSUPP, tryCancel, poll, flags, clearTimer, register2, LocCompleteIndex, days, ENOSTR, EADDRINUSE, one, ENAMETOOLONG, EMULTIHOP, ESTALE, await, ENODATA, EFBIG, +, minutes, ERFKILL, cancelled, toException, or, EDEADLOCK, allFutures, MaxEventsCount, wait, read, raiseAsDefect, Millisecond, setTimer, unregister2, failed, waitFor, newFutureSeq, callback=, orImpl, ECONNREFUSED, high, ENOTNAM, nanos, addWriter2, removeTimer, EINTR, join, closeHandle, EL3RST, readError, *, newFuture, EDQUOT, createStreamServer, milliseconds, AsyncStreamError, createStreamServer, EMLINK, createStreamServer, milliseconds, EMFILE, $, release, fromNow, close, weeks, newAsyncQueue, getTransportOsError, read, id, <=, FutureCompletedError, waitFor, EPROTONOSUPPORT, cancelAndWait, createStreamServer, failed, createStreamServer, setError, newAsyncStreamWriter, AsyncStreamWriterVtbl, removeTimer, race, $, ENOSPC, TransportUseClosedError, idleAsync, init, initTAddress, ENOKEY, Week, cancelSoon, awaitne, EREMOTE, EFAULT, epochSeconds, close, microseconds, AsyncEvent, weeks, cancelCallback=, ETOOMANYREFS, raiseAsyncStreamLimitError, TransportInitCallback, localAddress, StreamServerTrackerName, micros, wait, ENETDOWN, EACCES, EINVAL, full, EBADFD, seconds, AsyncStreamWriteError, read, raiseTransportOsError, finish, start, join, AsyncStreamIncorrectDefect, <=, init, completed, FutureBase, ==, $, ELIBBAD, TransportLimitError, or, cancelSoon, EILSEQ, allFutures, EADV, -, newAsyncStreamWriter, ==, location, addFirstNoWait, ENOLCK, FutureSeq, cancelAndWait, EPROTO, getConnectionAbortedError, value, ENODEV, close, ECHRNG, ERFKILL, setTimer, nanoseconds, init, closeWait, get, running, addTimer, race, ENOTTY, EISNAM, init, createStreamServer, ==, +, FutureFlags, getGlobalDispatcher, ELIBEXEC, E2BIG, -=, AsyncSemaphoreError, AsyncStreamReader, AsyncQueueEmptyError, newAsyncStreamWriter, <, checkWriteEof, fastEpochTime, resolveTAddress, $, read, PDispatcher, fromPipe2, TrackerCounter, write, localAddress2, start2, async, EREMCHG, Finished, StreamServer, SocketFlags, low, removeTimer, createStreamServer, release, Duration, failed, AsyncStreamDefaultQueueSize, initTAddress, getUserData, localAddress, orImpl, EROFS, seconds, init, readerOverflow, nanos, atEof, Nanosecond, race, ENODATA, init, +, EAFNOSUPPORT, DefaultStreamBufferSize, read, resolveTAddress, createStreamServer, failed, ELIBSCN, ENOTNAM, nanos, closeHandle, ENOTUNIQ, newFuture, popFirstNoWait, closeSocket, ECONNRESET, contains, Second, getSrcLocation, FutureError, getTransportTooManyError, init, withTimeout, EREMOTEIO, initTAddress, stopped, ENOENT, AsyncStreamReadError, setThreadDispatcher, EEXIST, ENOMSG, ESHUTDOWN, removeWriter2, [], setDualstack, EWOULDBLOCK, Finished, readMessage, setGlobalDispatcher, TrackerBase, AsyncEventQueue, addCallback, TransportError, ESTRPIPE, EISCONN, callSoon, getServerUseClosedError, newAsyncStreamWriteEOFError, close, EBADF, microseconds, ETIMEDOUT, ReadMessagePredicate, Future, EL2NSYNC, ETIME, getDomain, EL2HLT, EIDRM, removeReader2, futureContinue, ENOANO, DefaultBacklogSize, register, ERANGE, done, popLastNoWait, init, ENONET, EPFNOSUPPORT, EMSGSIZE, EBADMSG, ENOPROTOOPT, newAsyncStreamWriter, closed, EDOTDOT, one, Minute, CancelledError, readLine, EOVERFLOW, raiseTransportError, newAsyncStreamReader, AnyAddress6, ENOTEMPTY, TimerCallback, EADDRNOTAVAIL, wait, AsyncStreamIncompleteError, WriteType, checkClosed, size, EUNATCH, newAsyncLock, div, ERESTART, availableSlots, newFutureStr, upload, FuturePendingError, unregisterAndCloseFd, LocFinishIndex, newAsyncEvent, ENOTBLK, race, InternalRaisesFuture, cancelSoon, cancel, micros, wait, unregister, EINPROGRESS, -, remoteAddress, new, AsyncStreamDefaultBufferSize, EDOM, EPIPE, AsyncLockError, getNoWait, len, EDESTADDRREQ, shutdownWait, removeCallback, EAGAIN, FutureFlag, read, async, resolveTAddress, emit, ENXIO, noCancel, init, ECONNABORTED, state, EBFONT, [], EDEADLK, ENOEXEC, asyncCheck, locked, readError, ZeroDuration, []=, ENOSYS, EventQueueKey, ELIBMAX, EOPNOTSUPP, ENOSTR, one, getTransportError, newAsyncStreamReader, AsyncStream, checkClosed, Raising, popFirst, join, read, items, Millisecond, consume, [], []=, ECONNREFUSED, addWriter2, EL3HLT, join, readError, *, CallbackFunc, EHOSTUNREACH, EHOSTDOWN, ECANCELED, init, +=, completed, internalRaiseIfError, newInternalRaisesFuture, ESPIPE, LocationKind, TransportAddress, SomeIntegerI64, complete, AsyncBufferRef, internalInitFutureBase, AddressFamily, nanoseconds, host, ECOMM, init, closed, join, millis, AsyncBuffer, ENOTCONN, EBUSY, ReadOnceProc, days, sleepAsync, +=, initUdata, consume, isZero, StreamReaderLoop, AsyncStreamReaderVtbl, NestedPoll, ENOMEM, addFirst, EKEYEXPIRED, EPERM, AsyncCallback, fromPipe, newAsyncEventQueue, DefaultDatagramBufferSize, ESOCKTNOSUPPORT, EHWPOISON, AsyncQueue, EXDEV, EKEYREVOKED, toIpAddress, hours, TransportIncompleteError, InfiniteDuration, setDualstack, clear, ==, ESRCH, fire, fromSAddr, ENOMEDIUM, secs, getThreadDispatcher, write, isAvailable, AsyncStreamRW, waitFor, isSet, value, SocketServer, tryCancel, addLastNoWait, getTransportOsError, read, waitFor, epochNanoSeconds, ENOPKG, newAsyncStreamWriter, WriteItem, EBADE, len, getAsyncTimestamp, readUntil, FutureState, EBADR, close, put, EKEYREJECTED, init, EISDIR, address, StreamWriterLoop, ESRMNT, ENAVAIL, error, write, anyAddressFix, AsyncError, EBADRQC, ENFILE, createStreamServer, failed, getAutoAddresses, mitems, getUserData, ETXTBSY, withTimeout, flags, DispatcherHandle, ELIBACC, Day, minutes, DualStackType, cancelAndWait, AsyncStreamWriter, cancelAndWait, toException, init, EBADSLT, closed, TransportUseEofError, ENETRESET, waitEvents, ThreadCallbackFunc, AsyncStreamState, wait, asyncSpawn, removeCallback, AsyncLock, getConnectionAbortedError, init, addCallback, clearTimer, newAsyncStreamReader, AsyncFD, ECHILD, newAsyncStreamUseClosedError, consume, WriteProc, LocCreateIndex, AsyncStreamWriterTrackerName, ==, StreamTransportTrackerName, getError, join, millis, EMEDIUMTYPE, sleepAsync, getDomain, callback=, acquire, EIO, write, FutureStr, high, poll, days, ==, ESTALE, minutes, toException, MaxEventsCount, wait, raiseAsDefect, newAsyncStreamReader, consume, addReader2, unregister2, callback=, high, toString, EINTR, init, raiseAsyncStreamWriteEOFError, toHex, fail, popLast, transfer, running, AsyncStreamWriteEOFError, StreamCallback, readOnce, closeWait, AsyncStreamLimitError, internalRaiseIfError, connect, fail, addTimer, race, Moment, EPROTOTYPE, AsyncExceptionError, ENOCSI, init, now, await, or, AsyncTimeoutError, createStreamServer, ENOLINK, tryAcquire, finished, +, StreamTransport, newAsyncStreamLimitError, init, newDispatcher, StreamCallback2, internalFail, TransportFlags, completed, handle, readOnce, newAsyncStreamWriter, error, ServerFlags, TransportTooManyError, readExactly, ELOOP, ENOSR, AsyncStreamReaderTrackerName, allFinished, ServerCommand, resolveTAddress, closeWait, finished, low, -=, setErrorAndRaise, TransportKind, stop2, Hour, init, writeFile, atEof, resolveTAddress, addLast, asyncTimer, contains, Microsecond, pairs, EOWNERDEAD, connect, readMessage, callSoon, readUntil, EALREADY, TransportOsError, addTimer, initTAddress, FutureDefect, ENOBUFS, <, one, cancelSoon, -, resolveTAddress, ENOTRECOVERABLE, ENOTDIR, hours, wait, cancelAndSchedule, *, getAutoAddress, readLine, ServerStatus, complete, EUSERS, EXFULL, EUCLEAN, accept, $, stepsAsync, clear, EventQueueReader, secs, read, waitFor, newAsyncStreamReader, newAsyncSemaphore, TransportNoSupport, empty, closeWait, write, AsyncSemaphore, raiseAsyncStreamIncompleteError, allFutures, SrcLoc, copyOut, raiseOsDefect, toSAddr, acquire, AsyncQueueFullError, write, TransportAbortedError, wait, newAsyncStreamReader, ELNRNG, raiseAsyncStreamUseClosedError, isInfinite, finished, AsyncStreamUseClosedError, InternalAsyncCallback, ENETUNREACH, InternalFutureBase, readExactly, getTransportUseClosedError, resolveTAddress, AsyncEventQueueFullError, init, atEof, resolveTAddress, register2, LocCompleteIndex, forget, EADDRINUSE, initSimpleVtbl, EMULTIHOP, putNoWait, AnyAddress, await, EFBIG, TransportAddressError, cancelled, EDEADLOCK, allFutures, newFutureSeq, newAsyncStreamIncompleteError, ENOTSOCK, TransportState, remoteAddress2, initSimpleVtbl, removeTimer, stop, EL3RST, ENAMETOOLONG, localAddress2, close, createStreamServer, createStreamServer, start2, StreamCallback2, getUserData, fromPipe, readLine, TransportFlags, ReadMessagePredicate, TransportInitCallback, localAddress, createStreamServer, running, StreamTransportTrackerName, StreamCallback, readExactly, createStreamServer, connect, join, finished, closeWait, closeWait, localAddress, TransportKind, write, write, writeFile, SocketFlags, atEof, createStreamServer, readMessage, shutdownWait, closed, StreamServer, accept, remoteAddress2, createStreamServer, close, readOnce, DefaultBacklogSize, write, createStreamServer, closed, connect, stop2, consume, toException, readUntil, read, createStreamServer, start, createStreamServer, consume, failed, createStreamServer, join, StreamServerTrackerName, StreamTransport, stop, remoteAddress, fromPipe2, read, Hour, init, fromNow, milliseconds, <, fastEpochTime, Minute, secs, microseconds, micros, ==, nanoseconds, +, nanos, minutes, <=, low, milliseconds, millis, $, micros, asyncTimer, +=, Nanosecond, -, -, Second, high, epochNanoSeconds, Microsecond, weeks, microseconds, secs, InfiniteDuration, -=, +, minutes, +=, Day, $, hours, toString, hours, Duration, now, <, weeks, Millisecond, <=, millis, ==, seconds, isZero, ZeroDuration, isInfinite, SomeIntegerI64, div, +, *, epochSeconds, high, nanoseconds, nanos, low, -, days, -=, Week, days, seconds, *, Moment, DualStackType, checkWriteEof, ==, toHex, getAutoAddress, address, getError, toIpAddress, $, resolveTAddress, anyAddressFix, TransportAddress, getAutoAddresses, initTAddress, AddressFamily, ==, ServerFlags, ServerStatus, host, ==, TransportState, setDualstack, $, getServerUseClosedError, getTransportOsError, TransportIncompleteError, $, TransportNoSupport, TransportUseClosedError, TransportUseEofError, resolveTAddress, TransportAbortedError, initTAddress, setDualstack, resolveTAddress, getDomain, toSAddr, TransportError, AnyAddress, resolveTAddress, getConnectionAbortedError, resolveTAddress, fromSAddr, $, TransportTooManyError, ==, checkClosed, ==, ServerCommand, getTransportUseClosedError, getTransportError, resolveTAddress, initTAddress, raiseTransportOsError, TransportOsError, getDomain, resolveTAddress, getTransportOsError, resolveTAddress, isAvailable, SocketServer, ==, DefaultDatagramBufferSize, TransportLimitError, getTransportTooManyError, TransportAddressError, DefaultStreamBufferSize, getConnectionAbortedError, raiseTransportError, AnyAddress6, checkClosed, initTAddress