chronos/apps/http/multipart

    Dark Mode
Search:
Group by:
  Source   Edit

Types

BChar = byte | char
  Source   Edit 
MultiPart = object
  case kind: MultiPartSource
  of MultiPartSource.Stream:
      breader: HttpBodyReader
      stream: BoundedStreamReader

  of MultiPartSource.Buffer:
      nil

  buffer: seq[byte]
  headers: HttpTable
  counter: int
  name*: string
  filename*: string
  Source   Edit 
MultiPartReader = object
  case kind*: MultiPartSource
  of MultiPartSource.Stream:
      stream*: HttpBodyReader

  of MultiPartSource.Buffer:
      nil

  firstTime: bool
  buffer: seq[byte]
  offset: int
  boundary: seq[byte]
  counter: int
  Source   Edit 
MultiPartSource {.pure.} = enum
  Stream, Buffer
  Source   Edit 
MultiPartWriter = object
  case kind*: MultiPartSource
  of MultiPartSource.Stream:
      stream*: HttpBodyWriter

  of MultiPartSource.Buffer:
      buffer*: seq[byte]

  beginMark: seq[byte]
  finishMark: seq[byte]
  beginPartMark: seq[byte]
  finishPartMark: seq[byte]
  state*: MultiPartWriterState
  Source   Edit 
MultiPartWriterState {.pure.} = enum
  MessagePreparing, MessageStarted, PartStarted, PartFinished, MessageFinished,
  MessageFailure
  Source   Edit

Procs

proc atEoM(mpr: MultiPartReaderRef): bool {....raises: [], tags: [RootEffect].}
Procedure returns true if MultiPartReader has reached the end of multipart message.   Source   Edit 
proc atEoM(mpr: var MultiPartReader): bool {....raises: [], tags: [RootEffect].}
Procedure returns true if MultiPartReader has reached the end of multipart message.   Source   Edit 
proc begin(mpw: MultiPartWriterRef): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
Starts multipart message form and write approprate markers to output stream.   Source   Edit 
proc begin(mpw: var MultiPartWriter) {....raises: [], tags: [].}
Starts multipart message form and write approprate markers to output buffer.   Source   Edit 
proc beginPart(mpw: MultiPartWriterRef; name: string; filename: string;
               headers: HttpTable): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}

Starts part of multipart message and write appropriate headers to the output stream.

Note: filename and name arguments could be only ASCII strings.

  Source   Edit 
proc beginPart(mpw: var MultiPartWriter; name: string; filename: string;
               headers: HttpTable) {....raises: [], tags: [].}

Starts part of multipart message and write appropriate headers to the output stream.

Note: filename and name arguments could be only ASCII strings.

  Source   Edit 
proc closeWait(mp: MultiPart): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}
Close and release MultiPart's mp stream and resources.   Source   Edit 
proc closeWait(mpr: MultiPartReaderRef): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}
Close and release MultiPartReader's mpr stream and resources.   Source   Edit 
proc consumeBody(mp: MultiPart): InternalRaisesFuture[void,
    (CancelledError, HttpReadError, HttpProtocolError)] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
Discard multipart's mp value.   Source   Edit 
proc finish(mpw: MultiPartWriterRef): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
Finish multipart's message form and send finishing markers to the output stream.   Source   Edit 
proc finish(mpw: var MultiPartWriter): seq[byte] {....raises: [], tags: [].}
Finish multipart's message form and send finishing markers to the output stream.   Source   Edit 
proc finishPart(mpw: MultiPartWriterRef): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
Finish multipart's message part and send proper markers to output stream.   Source   Edit 
proc finishPart(mpw: var MultiPartWriter) {....raises: [], tags: [].}
Finish multipart's message part and send proper markers to output stream.   Source   Edit 
proc getBody(mp: MultiPart): InternalRaisesFuture[seq[byte],
    (CancelledError, HttpReadError, HttpProtocolError)] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
Get multipart's mp value as sequence of bytes.   Source   Edit 
proc getBodyStream(mp: MultiPart): HttpResult[AsyncStreamReader] {....raises: [],
    tags: [].}
Get multipart's mp stream, which can be used to obtain value of the part.   Source   Edit 
proc getBytes(mp: MultiPart): seq[byte] {....raises: [], tags: [RootEffect].}
Returns value for MultiPart mp as sequence of bytes.   Source   Edit 
func getMultipartBoundary(contentData: ContentTypeData): HttpResult[string] {.
    ...raises: [], tags: [].}
Returns multipart/form-data boundary value from Content-Type header.
The procedure carries out all the necessary checks:
  1. boundary value must be present.
  2. boundary value must be less then 70 characters length and all characters should be part of specific alphabet.
  Source   Edit 
proc getPart(mpr: var MultiPartReader): Result[MultiPart, string] {....raises: [],
    tags: [].}

Get multipart part from MultiPartReader instance.

This procedure will work only for MultiPartReader with buffer source.

  Source   Edit 
proc getString(mp: MultiPart): string {....raises: [], tags: [RootEffect].}
Returns value for MultiPart mp as string.   Source   Edit 
proc init[A: BChar; B: BChar](mpt: typedesc[MultiPartReader];
                              buffer: openArray[A]; boundary: openArray[B]): MultiPartReader {.
    ...raises: [].}

Create new MultiPartReader instance with buffer interface.

buffer - is buffer which will be used to read data. boundary - is multipart boundary, this value must not be empty.

  Source   Edit 
proc init[B: BChar](mpt: typedesc[MultiPartWriter]; boundary: openArray[B]): MultiPartWriter {.
    ...raises: [].}

Create new MultiPartWriter instance with buffer interface.

boundary - is multipart boundary, this value must not be empty.

  Source   Edit 
func isEmpty(mp: MultiPart): bool {....raises: [], tags: [].}
Returns true is multipart mp is not initialized/filled yet.   Source   Edit 
proc new[B: BChar](mpt: typedesc[MultiPartReaderRef]; stream: HttpBodyReader;
                   boundary: openArray[B];
                   partHeadersMaxSize = MaxMultipartHeaderSize): MultiPartReaderRef {.
    ...raises: [].}

Create new MultiPartReader instance with stream interface.

stream is stream used to read data. boundary is multipart boundary, this value must not be empty. partHeadersMaxSize is maximum size of multipart's headers.

  Source   Edit 
proc new[B: BChar](mpt: typedesc[MultiPartWriterRef]; stream: HttpBodyWriter;
                   boundary: openArray[B]): MultiPartWriterRef {....raises: [].}
  Source   Edit 
proc readPart(mpr: MultiPartReaderRef): InternalRaisesFuture[MultiPart,
    (CancelledError, HttpReadError, HttpProtocolError)] {.stackTrace: false,
    ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
  Source   Edit 
proc write(mpw: MultiPartWriterRef; data: seq[byte]): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
Write part's data data to the output stream.   Source   Edit 
proc write(mpw: MultiPartWriterRef; data: string): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [], gcsafe,
                                        raises: [], raises: [],
                                        tags: [RootEffect].}
Write part's data data to the output stream.   Source   Edit 
proc write(mpw: MultiPartWriterRef; pbytes: pointer; nbytes: int): InternalRaisesFuture[
    void, (CancelledError, HttpWriteError)] {.stackTrace: false, ...raises: [],
    gcsafe, raises: [], raises: [], tags: [RootEffect].}
Write part's data data to the output stream.   Source   Edit 
proc write(mpw: var MultiPartWriter; data: openArray[byte]) {....raises: [],
    tags: [].}
Write part's data data to the output stream.   Source   Edit 
proc write(mpw: var MultiPartWriter; data: openArray[char]) {....raises: [],
    tags: [].}
Write part's data data to the output stream.   Source   Edit 
proc write(mpw: var MultiPartWriter; pbytes: pointer; nbytes: int) {....raises: [],
    tags: [].}
Write part's data data to the output stream.   Source   Edit

Exports

setThreadDispatcher, closeSocket, ENOSR, EHOSTUNREACH, EHOSTDOWN, ECONNRESET, EDQUOT, fail, ECANCELED, EMLINK, FuturePendingError, milliseconds, <=, +=, $, asyncTimer, internalRaiseIfError, getSrcLocation, FutureError, fromNow, weeks, ESPIPE, withTimeout, LocationKind, id, <=, FutureCompletedError, ENOEXEC, ESHUTDOWN, fail, EREMOTEIO, toString, EDESTADDRREQ, waitFor, complete, internalInitFutureBase, EPROTONOSUPPORT, Nanosecond, cancelAndWait, addTimer, Moment, ECOMM, EPROTOTYPE, AsyncExceptionError, milliseconds, getTrackerCounter, ENOENT, millis, removeTimer, ==, FutureFlag, ENOTCONN, EBUSY, init, ENOTUNIQ, days, +=, race, or, EKEYREVOKED, AsyncTimeoutError, EUCLEAN, Second, EEXIST, ENOLINK, newInternalRaisesFuture, idleAsync, internalRaiseIfError, SomeIntegerI64, ENOMEM, ENOKEY, +, removeWriter2, ENOMSG, [], trackCounter, EKEYEXPIRED, Week, isCounterLeaked, awaitne, EAFNOSUPPORT, EWOULDBLOCK, EREMOTE, finished, untrackCounter, AsyncCallback, EHWPOISON, epochSeconds, newDispatcher, EPERM, microseconds, trackerCounters, internalFail, weeks, Finished, cancelCallback=, ETOOMANYREFS, $, EISCONN, callSoon, ESOCKTNOSUPPORT, setGlobalDispatcher, EXDEV, EBADF, cancelSoon, allFinished, TrackerBase, hours, InternalAsyncCallback, EBFONT, ENETDOWN, EACCES, ELOOP, InfiniteDuration, ETIMEDOUT, EINVAL, value, EBADFD, Future, completed, PDispatcher, ESRCH, EL2NSYNC, Finished, low, ESTRPIPE, -=, ==, ENOTSOCK, getAsyncTimestamp, SrcLoc, Hour, EIDRM, removeReader2, secs, getThreadDispatcher, futureContinue, isZero, ENOANO, EADV, CallbackFunc, contains, cancelAndWait, $, ENFILE, FutureBase, waitFor, high, Microsecond, ENOPKG, ELIBBAD, callSoon, EOWNERDEAD, ERANGE, done, or, ENONET, completed, callSoon, cancelSoon, EMSGSIZE, EALREADY, EBADMSG, EILSEQ, ENOPROTOOPT, EXFULL, allFutures, -, complete, FutureState, EBADR, nanos, location, FutureDefect, EDOTDOT, ENOBUFS, EKEYREJECTED, <, Minute, error, one, CancelledError, nanoseconds, EISDIR, sleepAsync, EOVERFLOW, FutureSeq, cancelAndWait, micros, -, ESRMNT, ENOTEMPTY, race, TimerCallback, microseconds, error, ENOTRECOVERABLE, wait, callIdle, EDOM, value, hours, AsyncError, EBADRQC, ENODEV, tryCancel, addTimer, ECHRNG, ENOTDIR, EUNATCH, cancelAndSchedule, failed, nanoseconds, ERESTART, *, ETXTBSY, getTracker, newFutureStr, EMFILE, LocFinishIndex, withTimeout, addTimer, await, EUSERS, ENOTBLK, EISNAM, ELIBACC, ENAVAIL, init, race, internalCallTick, ==, Day, +, cancelSoon, completed, minutes, cancel, FutureFlags, getGlobalDispatcher, ELIBEXEC, stepsAsync, micros, wait, cancelAndWait, EINPROGRESS, EPFNOSUPPORT, E2BIG, -=, runForever, ENOMEDIUM, secs, read, waitFor, EL3HLT, unregisterAndCloseFd, EBADSLT, -, <, ENETRESET, fastEpochTime, ENXIO, join, EPIPE, allFutures, EPROTO, ENOTTY, wait, now, read, asyncSpawn, removeCallback, EAGAIN, raiseOsDefect, trackerCounterKeys, EADDRNOTAVAIL, read, removeCallback, TrackerCounter, async, addCallback, init, async, ZeroDuration, EREMCHG, EFAULT, addCallback, seconds, noCancel, low, AsyncFD, ECHILD, Raising, init, ECONNABORTED, state, wait, callIdle, removeTimer, LocCreateIndex, addReader2, ETIME, ENOLCK, EDEADLK, asyncCheck, Duration, ELNRNG, ENOCSI, millis, EBADE, EMEDIUMTYPE, readError, sleepAsync, isInfinite, callback=, ENETUNREACH, InternalFutureBase, callIdle, ENOSPC, ENOSYS, ELIBSCN, EIO, EROFS, seconds, ELIBMAX, await, div, init, EL2HLT, EOPNOTSUPP, FutureStr, poll, flags, clearTimer, register2, LocCompleteIndex, days, ENOSTR, EADDRINUSE, one, ENAMETOOLONG, EMULTIHOP, epochNanoSeconds, ESTALE, race, ENODATA, EFBIG, +, minutes, ERFKILL, cancelled, toException, InternalRaisesFuture, EDEADLOCK, allFutures, MaxEventsCount, wait, read, raiseAsDefect, Millisecond, setTimer, cancelSoon, unregister2, failed, waitFor, newFutureSeq, addTracker, callback=, orImpl, ECONNREFUSED, high, ENOTNAM, nanos, addWriter2, removeTimer, internalCallTick, EINTR, join, closeHandle, EL3RST, readError, *, newFuture, internalCallTick, HttpTables, new, getInt, getLastString, isEmpty, getString, new, items, count, clear, getList, HttpTable, HttpTableRef, stringItems, contains, normalizeHeaderName, $, add, init, hasKeyOrPut, toList, add, set, init, getLastInt, ContentEncodingHeader, EDQUOT, availableSlots, milliseconds, ==, EMLINK, milliseconds, EMFILE, $, release, fromNow, DateHeader, weeks, LocFinishIndex, addLastNoWait, id, FutureCompletedError, waitFor, EPROTONOSUPPORT, cancelAndWait, ExpectHeader, removeTimer, ContentLengthHeader, race, $, ENOSPC, newHttpInterruptError, idleAsync, ENOKEY, HttpServerResponseTrackerName, Week, cancelSoon, awaitne, HttpRecoverableError, [], EREMOTE, EFAULT, epochSeconds, microseconds, AsyncEvent, weeks, cancelCallback=, ETOOMANYREFS, getContentEncoding, micros, HttpError, wait, ENETDOWN, EACCES, ContentDispositionHeader, bytesToString, EINVAL, full, QueryParamsFlag, EBADFD, seconds, ==, join, UrlEncodedContentType, <=, init, completed, FutureBase, ELIBBAD, HttpServerUnsecureConnectionTrackerName, getContentType, or, cancelSoon, EILSEQ, allFutures, EADV, -, location, addFirstNoWait, ConnectionHeader, ENOLCK, FutureSeq, cancelAndWait, EPROTO, callIdle, HttpRequestError, value, ENODEV, tryCancel, ECHRNG, ERFKILL, setTimer, nanoseconds, closeWait, get, stringToBytes, addTimer, race, ENOTTY, EISNAM, init, +, FutureFlags, getGlobalDispatcher, ELIBEXEC, raiseHttpProtocolError, E2BIG, -=, AsyncSemaphoreError, AsyncQueueEmptyError, <, fastEpochTime, $, HttpUseClosedError, read, LocationHeader, TrackerCounter, HeadersMark, async, EREMCHG, Finished, low, ProxyAuthorizationHeader, removeTimer, release, Duration, failed, toString, HttpReadError, orImpl, EROFS, seconds, init, HttpServerSecureConnectionTrackerName, nanos, HttpCriticalError, HttpResultCode, Nanosecond, race, ENODATA, init, +, raiseHttpProtocolError, EAFNOSUPPORT, raiseHttpWriteError, ELIBSCN, ENOTNAM, nanos, isPersistent, closeHandle, ENOTUNIQ, newFuture, popFirstNoWait, isCriticalError, raiseHttpInterruptError, closeSocket, ECONNRESET, contains, Second, getSrcLocation, FutureError, withTimeout, EREMOTEIO, HttpRequestHeadersTooLargeError, ENOENT, raiseHttpRequestBodyTooLargeError, setThreadDispatcher, EEXIST, ENOMSG, ESHUTDOWN, removeWriter2, [], isCounterLeaked, EWOULDBLOCK, Finished, untrackCounter, EHWPOISON, setGlobalDispatcher, TrackerBase, HttpResultMessage, AsyncEventQueue, addCallback, ESTRPIPE, EISCONN, callSoon, EBADF, microseconds, ETIMEDOUT, Future, queryParams, EL2NSYNC, ETIME, EL2HLT, EIDRM, removeReader2, futureContinue, ENOANO, raiseHttpReadError, AuthorizationHeader, raiseHttpConnectionError, register, ERANGE, done, popLastNoWait, ENONET, EPFNOSUPPORT, raiseHttpAddressError, EMSGSIZE, EBADMSG, ENOPROTOOPT, EDOTDOT, Minute, CancelledError, EOVERFLOW, HttpAddressErrorType, ENOTEMPTY, TimerCallback, EADDRNOTAVAIL, wait, size, EUNATCH, newAsyncLock, div, ERESTART, newFutureStr, FuturePendingError, unregisterAndCloseFd, newAsyncQueue, popFirst, UserAgentHeader, ENOTBLK, race, InternalRaisesFuture, cancelSoon, cancel, micros, wait, unregister, EINPROGRESS, -, EDOM, EPIPE, AsyncLockError, getNoWait, len, EDESTADDRREQ, removeCallback, EAGAIN, FutureFlag, read, async, emit, ENXIO, HostHeader, noCancel, init, raiseHttpProtocolError, ECONNABORTED, state, EBFONT, [], EDEADLK, ENOEXEC, asyncCheck, locked, HttpRedirectError, ZeroDuration, []=, ENOSYS, EventQueueKey, ELIBMAX, EOPNOTSUPP, raiseHttpCriticalError, ENOSTR, one, MultipartContentType, Raising, newAsyncEvent, read, items, Millisecond, readError, []=, callIdle, ECONNREFUSED, addWriter2, EL3HLT, join, readError, *, asyncTimer, <=, EHOSTUNREACH, EHOSTDOWN, newHttpWriteError, ECANCELED, init, HttpServerRequestTrackerName, +=, completed, internalRaiseIfError, newInternalRaisesFuture, ESPIPE, LocationKind, SomeIntegerI64, complete, internalInitFutureBase, nanoseconds, ECOMM, PostMethods, init, getTrackerCounter, millis, ENOTCONN, EBUSY, days, sleepAsync, +=, HttpState, internalCallTick, isZero, internalRaiseIfError, ENOMEM, addFirst, EKEYEXPIRED, or, EPERM, HttpConnectionError, AsyncCallback, HttpWriteError, trackerCounters, newAsyncEventQueue, ESOCKTNOSUPPORT, AsyncQueue, EXDEV, EKEYREVOKED, encodeBasicAuth, hours, InfiniteDuration, clear, HttpMessage, HttpTransportError, ESRCH, fire, ENOMEDIUM, secs, getThreadDispatcher, waitFor, isSet, value, close, waitFor, epochNanoSeconds, ENOPKG, callSoon, bytesToString, EBADE, len, getAsyncTimestamp, FutureState, EBADR, ==, put, EKEYREJECTED, EISDIR, ESRMNT, HttpResponseError, ENAVAIL, error, AsyncError, EBADRQC, ENFILE, failed, mitems, ETXTBSY, withTimeout, flags, ELIBACC, Day, minutes, KeyValueTuple, cancelAndWait, runForever, cancelAndWait, EBADSLT, ENETRESET, waitEvents, wait, getTransferEncoding, asyncSpawn, removeCallback, AsyncLock, init, addCallback, clearTimer, AsyncFD, ECHILD, callIdle, HttpInterruptError, LocCreateIndex, RecoverableHttpAddressError, millis, EMEDIUMTYPE, sleepAsync, callback=, acquire, EIO, FutureStr, high, poll, days, ESTALE, minutes, HttpDisconnectError, toException, MaxEventsCount, wait, raiseAsDefect, addReader2, unregister2, addTracker, callback=, high, newHttpReadError, CriticalHttpAddressError, toString, internalCallTick, EINTR, internalCallTick, fail, popLast, stringToBytes, HttpReadLimitError, isRecoverableError, fail, addTimer, Moment, EPROTOTYPE, AsyncExceptionError, SrcLoc, HttpRequestBodyTooLargeError, ENOCSI, init, HttpAddressError, now, await, AsyncTimeoutError, ENOLINK, tryAcquire, TransferEncodingHeader, +, trackCounter, newDispatcher, internalFail, HttpInvalidUsageError, completed, error, ELOOP, ENOSR, allFinished, $, HttpProtocolError, PDispatcher, trackerCounterKeys, HttpRequestHeadersError, finished, low, -=, HttpResult, AcceptHeaderName, Hour, readerOverflow, addLast, CallbackFunc, contains, Microsecond, pairs, EOWNERDEAD, ContentEncodingFlags, callSoon, EALREADY, addTimer, FutureDefect, ENOBUFS, <, one, raiseHttpRedirectError, cancelSoon, -, ENOTRECOVERABLE, ENOTDIR, hours, cancelAndSchedule, *, getTracker, complete, EUSERS, EXFULL, EUCLEAN, stepsAsync, clear, EventQueueReader, secs, newHttpUseClosedError, read, waitFor, MaximumBodySizeError, newAsyncSemaphore, empty, AsyncSemaphore, allFutures, raiseOsDefect, acquire, AsyncQueueFullError, ContentTypeHeader, wait, ELNRNG, ServerHeader, isInfinite, InternalAsyncCallback, ENETUNREACH, InternalFutureBase, AsyncEventQueueFullError, HttpRequestBodyError, register2, LocCompleteIndex, TransferEncodingFlags, EMULTIHOP, putNoWait, await, EFBIG, cancelled, EDEADLOCK, allFutures, newFutureSeq, ENOTSOCK, raiseHttpDisconnectError, EADDRINUSE, removeTimer, EL3RST, ENAMETOOLONG, hasOverflow, closed, HttpBodyWriter, closeWait, closeWait, HttpBodyWriterTrackerName, HttpBodyReaderTrackerName, newHttpBodyReader, newHttpBodyWriter, HttpBodyReader, EDQUOT, availableSlots, createStreamServer, milliseconds, ==, AsyncStreamError, createStreamServer, EMLINK, createStreamServer, milliseconds, EMFILE, $, release, fromNow, close, weeks, LocFinishIndex, getTransportOsError, ==, read, id, <=, FutureCompletedError, waitFor, EPROTONOSUPPORT, cancelAndWait, createStreamServer, failed, createStreamServer, setError, newAsyncStreamWriter, AsyncStreamWriterVtbl, removeTimer, ==, race, EAFNOSUPPORT, 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, callIdle, 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, toHex, 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, +, 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, isCounterLeaked, EWOULDBLOCK, Finished, untrackCounter, readMessage, setGlobalDispatcher, TrackerBase, AsyncEventQueue, addCallback, TransportError, ESTRPIPE, WriteProc, 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, newFutureStr, FuturePendingError, unregisterAndCloseFd, newAsyncQueue, popFirst, 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, newAsyncEvent, join, read, items, Millisecond, consume, []=, callIdle, ECONNREFUSED, addWriter2, EL3HLT, join, readError, *, asyncTimer, EHOSTUNREACH, EHOSTDOWN, ECANCELED, init, +=, completed, internalRaiseIfError, newInternalRaisesFuture, ESPIPE, LocationKind, TransportAddress, SomeIntegerI64, complete, AsyncBufferRef, internalInitFutureBase, AddressFamily, nanoseconds, host, ECOMM, init, closed, join, getTrackerCounter, millis, AsyncBuffer, ENOTCONN, EBUSY, ReadOnceProc, days, sleepAsync, +=, initUdata, consume, internalCallTick, isZero, StreamReaderLoop, AsyncStreamReaderVtbl, internalRaiseIfError, ENOMEM, addFirst, EKEYEXPIRED, or, EPERM, AsyncCallback, trackerCounters, 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, FutureStr, addLastNoWait, getTransportOsError, read, waitFor, epochNanoSeconds, ENOPKG, newAsyncStreamWriter, callSoon, 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, ELIBACC, Day, minutes, DualStackType, cancelAndWait, AsyncStreamWriter, runForever, cancelAndWait, toException, init, EBADSLT, closed, TransportUseEofError, ENETRESET, waitEvents, upload, AsyncStreamState, wait, asyncSpawn, removeCallback, AsyncLock, getConnectionAbortedError, init, addCallback, clearTimer, newAsyncStreamReader, AsyncFD, ECHILD, newAsyncStreamUseClosedError, consume, callIdle, LocCreateIndex, AsyncStreamWriterTrackerName, StreamTransportTrackerName, getError, join, millis, EMEDIUMTYPE, sleepAsync, getDomain, callback=, acquire, EIO, write, tryCancel, high, poll, days, ESTALE, minutes, toException, MaxEventsCount, wait, raiseAsDefect, newAsyncStreamReader, consume, addReader2, unregister2, addTracker, callback=, high, toString, internalCallTick, EINTR, init, internalCallTick, raiseAsyncStreamWriteEOFError, closeWait, fail, popLast, transfer, running, AsyncStreamWriteEOFError, StreamCallback, readOnce, closeWait, AsyncStreamLimitError, connect, fail, addTimer, Moment, EPROTOTYPE, AsyncExceptionError, SrcLoc, ENOCSI, init, now, await, AsyncTimeoutError, createStreamServer, ENOLINK, tryAcquire, finished, +, StreamTransport, newAsyncStreamLimitError, trackCounter, init, newDispatcher, StreamCallback2, internalFail, TransportFlags, completed, readOnce, newAsyncStreamWriter, error, ServerFlags, TransportTooManyError, readExactly, ELOOP, ENOSR, AsyncStreamReaderTrackerName, allFinished, ServerCommand, resolveTAddress, $, PDispatcher, trackerCounterKeys, finished, low, -=, ==, setErrorAndRaise, TransportKind, stop2, Hour, init, writeFile, atEof, resolveTAddress, addLast, CallbackFunc, contains, Microsecond, pairs, EOWNERDEAD, connect, readMessage, callSoon, readUntil, EALREADY, TransportOsError, addTimer, initTAddress, FutureDefect, ENOBUFS, <, cancelSoon, -, resolveTAddress, ENOTRECOVERABLE, ENOTDIR, hours, wait, cancelAndSchedule, *, getTracker, getAutoAddress, readLine, ServerStatus, complete, EUSERS, EXFULL, EUCLEAN, accept, stepsAsync, clear, EventQueueReader, secs, read, waitFor, newAsyncStreamReader, newAsyncSemaphore, TransportNoSupport, empty, closeWait, ==, write, AsyncSemaphore, raiseAsyncStreamIncompleteError, allFutures, 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

Made with Nim. Generated: 2026-06-24 14:58:56 UTC