* Called befor a pause task, */

called when the connection was closed, but will not run concurrently */

called when a request was received. */

called when a response was received. */

* called after the resume task had completed. */

Push for data - unsupported. */

Push for files - unsupported. */

Should send existing headers and data */

Should send existing headers and file */

* Closes an EventSource (SSE) connection. */

* Writes data to an EventSource (SSE) connection. * * See the {struct http_sse_write_args} for possible named arguments. */

* Upgrades an HTTP connection to an EventSource (SSE) connection. * * Thie `http_s` handle will be invalid after this call. * * On HTTP/1.1 connec

Registers a Mime-Type to be associated with the file extension. */

* Attempts to decode the request's body. * * Supported Types include: * * application/x-www-form-urlencoded * * application/json * * multipart/fo

Parses any Cookie / Set-Cookie headers, using the `http_add2hash` scheme. */

* Defers the request / response handling for later. */

perform the pause task outside of the connection's lock */

Returns the `udata` associated with the paused opaque handle */

* Sets the `udata` associated with the paused opaque handle, returning the * old value. */

* Pushes a data response when supported (HTTP/2 only). * * Returns -1 on error and 0 on success. */

* Pushes a file response when supported (HTTP/2 only). * * If `mime_type` is NULL, an attempt at automatic detection using * `filename` will be mad

* Returns a String object representing the unparsed HTTP request (HTTP * version is capped at HTTP/1.1). Mostly usable for proxy usage and * debuggi

* Defers the request / response handling for later. */

perform the resume task fallback */

perform the resume task within of the connection's lock */

* Closes an EventSource (SSE) connection. */

* Duplicates an SSE handle by reference, remember to http_sse_free. * * Returns the same object (increases a reference count, no allocation is made)

* Frees an SSE handle by reference (decreases the reference count). */

The on message callback. the `*msg` pointer is to a temporary object. */

An optional callback for when a subscription is fully canceled. */

* Sets the ping interval for SSE connections. */

* Subscribes to a channel. See {struct http_sse_subscribe_args} for possible * arguments. * * Returns a subscription ID on success and 0 on failure

* Cancels a subscription and invalidates the subscription object. */

initialize library

* This function reviews the instructions listed at the end of the mustache_s * and performs any callbacks necessary. * * The `mustache_s` data is l

Calls a Ruby method on a given object, protecting against exceptions. */

Calls a Ruby method on a given object, protecting against exceptions. */

Calls a Ruby method on a given object, protecting against exceptions. */

* Parses the CLI argnumnents, returning the Rack filename (if provided). * * Unknown arguments are ignored. * * @params [String] desc a String con

clang-format off The {connect} method instructs iodine to connect to a server using either TCP/IP or Unix sockets. Iodine.connect(settings) Sup

Iodine::PubSub::Engine.allocate */

a callback for the GC (marking active objects) */

* Returns the connection's `env` (if it originated from an HTTP request). */

* Returns the client's current callback object. */

clang-format off * Sets the client's callback object, so future events will use the new object's callbacks. * * @Note this will fire the `on_close`

Returns true if the connection appears to be open (no known issues). */

* Always returns true, since Iodine connections support the pub/sub extension. */

* Returns the number of pending `write` operations that need to complete * before the next `on_drained` callback is called. * * Returns -1 if the c

clang-format off * Returns the connection's protocol Symbol (`:sse`, `:websocket` or `:raw`). * * @Note For compatibility reasons (with ther `rack.u

* Returns the timeout / `ping` interval for the connection. * * Returns nil on error. */

* Sets the timeout / `ping` interval for the connection (up to 255 seconds). * * Returns nil on error. */

* Writes data to the connection asynchronously. `data` MUST be a String. * * In effect, the `write` call does nothing, it only schedules the data to

Performs any cleanup before worker dies */

Runs the required block after the specified number of milliseconds have passed. Time is counted only once Iodine started running (using {Iodine.start}

clang-format off Runs the required block after the specified number of milliseconds have passed. Time is counted only once Iodine started running (usi

Returns the GVL state flag. */