chronos/apps/http/multipart

Search:
Group by:
Source   Edit  

Types

BChar = byte | char
Source   Edit   
MultiPart = object
  case
  of MultiPartSource.Stream:
  of MultiPartSource.Buffer:
    nil
  name*: string
  filename*: string
Source   Edit   
MultiPartReader = object
  case kind*: MultiPartSource
  of MultiPartSource.Stream:
    stream*: HttpBodyReader
  of MultiPartSource.Buffer:
    nil
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]
  state*: MultiPartWriterState
Source   Edit   
MultiPartWriterState {.pure.} = enum
  MessagePreparing, MessageStarted, PartStarted, PartFinished, MessageFinished,
  MessageFailure
Source   Edit  

Procs

proc atEoM(mpr: MultiPartReaderRef): bool {....raises: [], tags: [RootEffect],
    forbids: [].}
Procedure returns true if MultiPartReader has reached the end of multipart message. Source   Edit   
proc atEoM(mpr: var MultiPartReader): bool {....raises: [], tags: [RootEffect],
    forbids: [].}
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: [], tags: [RootEffect],
                                        forbids: [].}
Starts multipart message form and write approprate markers to output stream. Source   Edit   
proc begin(mpw: var MultiPartWriter) {....raises: [], tags: [], forbids: [].}
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: [], tags: [RootEffect],
                                        forbids: [].}

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: [], forbids: [].}

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: [], tags: [RootEffect],
    forbids: [].}
Close and release MultiPart's mp stream and resources. Source   Edit   
proc closeWait(mpr: MultiPartReaderRef): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
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: [], tags: [RootEffect], forbids: [].}
Discard multipart's mp value. Source   Edit   
proc finish(mpw: MultiPartWriterRef): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {....stackTrace: false, raises: [], gcsafe,
                                        raises: [], tags: [RootEffect],
                                        forbids: [].}
Finish multipart's message form and send finishing markers to the output stream. Source   Edit   
proc finish(mpw: var MultiPartWriter): seq[byte] {....raises: [], tags: [],
    forbids: [].}
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: [], tags: [RootEffect],
                                        forbids: [].}
Finish multipart's message part and send proper markers to output stream. Source   Edit   
proc finishPart(mpw: var MultiPartWriter) {....raises: [], tags: [], forbids: [].}
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: [], tags: [RootEffect], forbids: [].}
Get multipart's mp value as sequence of bytes. Source   Edit   
proc getBodyStream(mp: MultiPart): HttpResult[AsyncStreamReader] {....raises: [],
    tags: [], forbids: [].}
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],
    forbids: [].}
Returns value for MultiPart mp as sequence of bytes. Source   Edit   
func getMultipartBoundary(contentData: ContentTypeData): HttpResult[string] {.
    ...raises: [], tags: [], forbids: [].}

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: [], forbids: [].}

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],
                                        forbids: [].}
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: [], forbids: [].}
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: [], tags: [RootEffect], forbids: [].}
Source   Edit   
proc write(mpw: MultiPartWriterRef; data: seq[byte]): InternalRaisesFuture[void,
    (CancelledError, HttpWriteError)] {....stackTrace: false, raises: [], gcsafe,
                                        raises: [], tags: [RootEffect],
                                        forbids: [].}
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: [], tags: [RootEffect],
                                        forbids: [].}
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: [], tags: [RootEffect], forbids: [].}
Write part's data data to the output stream. Source   Edit   
proc write(mpw: var MultiPartWriter; data: openArray[byte]) {....raises: [],
    tags: [], forbids: [].}
Write part's data data to the output stream. Source   Edit   
proc write(mpw: var MultiPartWriter; data: openArray[char]) {....raises: [],
    tags: [], forbids: [].}
Write part's data data to the output stream. Source   Edit   
proc write(mpw: var MultiPartWriter; pbytes: pointer; nbytes: int) {....raises: [],
    tags: [], forbids: [].}
Write part's data data to the output stream. 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, 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, milliseconds, EMLINK, milliseconds, EMFILE, $, release, fromNow, DateHeader, weeks, newAsyncQueue, addLastNoWait, id, FutureCompletedError, waitFor, EPROTONOSUPPORT, cancelAndWait, ExpectHeader, toString, 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, HttpRequestError, value, ENODEV, FutureStr, ECHRNG, ERFKILL, setTimer, nanoseconds, closeWait, get, stringToBytes, addTimer, race, ENOTTY, EISNAM, init, +, FutureFlags, getGlobalDispatcher, ELIBEXEC, raiseHttpProtocolError, E2BIG, -=, AsyncSemaphoreError, AsyncQueueEmptyError, <, fastEpochTime, $, HttpProtocolError, read, LocationHeader, TrackerCounter, HeadersMark, async, EREMCHG, Finished, low, ProxyAuthorizationHeader, removeTimer, release, Duration, failed, HttpReadError, orImpl, EROFS, seconds, init, HttpServerSecureConnectionTrackerName, nanos, HttpCriticalError, HttpResultCode, Nanosecond, race, ENODATA, init, +, raiseHttpProtocolError, EAFNOSUPPORT, raiseHttpWriteError, ELIBSCN, ENOTNAM, nanos, isPersistent, closeHandle, ENOTUNIQ, getTransferEncodings, newFuture, popFirstNoWait, isCriticalError, raiseHttpInterruptError, closeSocket, ECONNRESET, contains, Second, getSrcLocation, FutureError, withTimeout, EREMOTEIO, HttpRequestHeadersTooLargeError, ENOENT, raiseHttpRequestBodyTooLargeError, setThreadDispatcher, EEXIST, ENOMSG, ESHUTDOWN, removeWriter2, [], EWOULDBLOCK, Finished, 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, ENOTEMPTY, TimerCallback, EADDRNOTAVAIL, wait, one, size, EUNATCH, newAsyncLock, div, ERESTART, availableSlots, newFutureStr, FuturePendingError, unregisterAndCloseFd, LocFinishIndex, newAsyncEvent, 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, popFirst, read, items, Millisecond, [], readError, []=, ECONNREFUSED, addWriter2, EL3HLT, join, readError, *, CallbackFunc, <=, EHOSTUNREACH, EHOSTDOWN, newHttpWriteError, ECANCELED, init, HttpServerRequestTrackerName, +=, completed, internalRaiseIfError, newInternalRaisesFuture, ESPIPE, LocationKind, SomeIntegerI64, complete, internalInitFutureBase, nanoseconds, ECOMM, PostMethods, init, millis, ENOTCONN, EBUSY, days, sleepAsync, +=, HttpState, HttpDisconnectError, isZero, NestedPoll, ENOMEM, addFirst, EKEYEXPIRED, EPERM, HttpConnectionError, AsyncCallback, HttpWriteError, newAsyncEventQueue, ESOCKTNOSUPPORT, AsyncQueue, EXDEV, EKEYREVOKED, encodeBasicAuth, hours, InfiniteDuration, clear, HttpMessage, HttpTransportError, ESRCH, fire, HttpUseClosedError, ENOMEDIUM, secs, getThreadDispatcher, waitFor, isSet, value, close, waitFor, epochNanoSeconds, ENOPKG, bytesToString, EBADE, len, getAsyncTimestamp, FutureState, EBADR, put, EKEYREJECTED, EISDIR, ESRMNT, HttpResponseError, ENAVAIL, error, AsyncError, EBADRQC, ENFILE, failed, mitems, ETXTBSY, withTimeout, flags, DispatcherHandle, ELIBACC, Day, getContentEncodings, minutes, KeyValueTuple, cancelAndWait, cancelAndWait, EBADSLT, ENETRESET, waitEvents, ThreadCallbackFunc, wait, getTransferEncoding, asyncSpawn, removeCallback, AsyncLock, init, addCallback, clearTimer, AsyncFD, ECHILD, HttpInterruptError, LocCreateIndex, RecoverableHttpAddressError, millis, EMEDIUMTYPE, sleepAsync, callback=, acquire, EIO, tryCancel, high, poll, days, ESTALE, minutes, toException, MaxEventsCount, wait, raiseAsDefect, addReader2, unregister2, callback=, high, newHttpReadError, CriticalHttpAddressError, toString, EINTR, fail, popLast, stringToBytes, HttpReadLimitError, isRecoverableError, internalRaiseIfError, fail, addTimer, race, Moment, EPROTOTYPE, AsyncExceptionError, HttpRequestBodyTooLargeError, ENOCSI, init, HttpAddressError, now, await, or, AsyncTimeoutError, ENOLINK, tryAcquire, TransferEncodingHeader, +, newDispatcher, internalFail, HttpInvalidUsageError, completed, handle, error, ELOOP, ENOSR, allFinished, PDispatcher, HttpRequestHeadersError, finished, low, -=, HttpResult, AcceptHeaderName, Hour, readerOverflow, addLast, asyncTimer, contains, Microsecond, pairs, EOWNERDEAD, ContentEncodingFlags, callSoon, EALREADY, addTimer, FutureDefect, ENOBUFS, <, one, raiseHttpRedirectError, cancelSoon, -, ENOTRECOVERABLE, ENOTDIR, hours, cancelAndSchedule, *, complete, EUSERS, EXFULL, EUCLEAN, $, stepsAsync, clear, EventQueueReader, secs, newHttpUseClosedError, read, waitFor, MaximumBodySizeError, newAsyncSemaphore, empty, AsyncSemaphore, allFutures, SrcLoc, raiseOsDefect, acquire, AsyncQueueFullError, ContentTypeHeader, wait, ELNRNG, ServerHeader, isInfinite, InternalAsyncCallback, ENETUNREACH, InternalFutureBase, AsyncEventQueueFullError, HttpRequestBodyError, register2, LocCompleteIndex, TransferEncodingFlags, EMULTIHOP, putNoWait, await, HttpAddressErrorType, EFBIG, cancelled, EDEADLOCK, allFutures, newFutureSeq, ENOTSOCK, raiseHttpDisconnectError, EADDRINUSE, removeTimer, EL3RST, ENAMETOOLONG, hasOverflow, closed, HttpBodyWriter, closeWait, closeWait, HttpBodyWriterTrackerName, HttpBodyReaderTrackerName, newHttpBodyReader, newHttpBodyWriter, HttpBodyReader, 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

Made with Nim. Generated: 2026-09-02 18:02:29 UTC