mooncakes.io

README

mizchi/x/http does not have a README file

#
HttpError

pub suberror HttpError {
  NetworkError(String)
  InvalidUrl(String)
  TimeoutError
  NotSupported
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for HttpError

#
Addr

source

pub(all) struct Addr {
  text : String
  port : Int
}

#
Client

source

pub struct Client {
  inner : @moonbitlang/async/http.Client
Client
  // private fields
}

impl Reader for Client

impl Writer for Client

#
Client::close

source

fn Client::close(self : Client) -> Unit

#
Client::end_request

source

async fn Client::end_request(self : Client) -> Response raise HttpError

#
Client::enter_passthrough_mode

source

async fn Client::enter_passthrough_mode(self : Client) -> Unit raise HttpError

#
Client::flush

source

async fn Client::flush(self : Client) -> Unit raise HttpError

#
Client::get

source

async fn Client::get(self : Client, path : String, extra_headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data) -> Response raise HttpError

#
Client::new

source

async fn Client::new(url : String, headers? : Map[String, String], proxy? : Client, verify? : Bool, trust? : @moonbitlang/async/tls.TrustedRoot
TrustedRoot) -> Client raise HttpError

#
Client::post

source

async fn Client::post(self : Client, path : String, body : &@moonbitlang/async/io.Data
Data, extra_headers? : Map[String, String]) -> Response raise HttpError

#
Client::put

source

async fn Client::put(self : Client, path : String, body : &@moonbitlang/async/io.Data
Data, extra_headers? : Map[String, String]) -> Response raise HttpError

#
Client::request

source

async fn Client::request(self : Client, meth : RequestMethod, path : StringView, extra_headers? : Map[String, String]) -> Unit raise HttpError

#
Client::skip_response_body

source

async fn Client::skip_response_body(self : Client) -> Unit raise HttpError

pub struct Cookie {
  name : String
  value : String
  path : String?
  expires_raw : String?
  max_age : Int64?
  domain : String?
  secure : Bool
  http_only : Bool
  extensions : Array[String]
} derive(@moonbitlang/core/debug.Debug
Debug)

#alias(new, deprecated="`new` is deprecated, use `Cookie` instead")
fn Cookie::Cookie(name : String, value : String, path? : String, expires_raw? : String, max_age? : Int64, domain? : String, secure? : Bool, http_only? : Bool, extensions? : Array[String]) -> Cookie

#
Request

source

pub(all) struct Request {
  meth : RequestMethod
  path : String
  headers : Map[String, String]
}

#
RequestMethod

source

pub(all) enum RequestMethod {
  Get
  Head
  Post
  Put
  Delete
  Connect
  Options
  Trace
  Patch
} derive(Compare, Eq, Hash, @moonbitlang/core/debug.Debug
Debug)

impl Show for RequestMethod

#
Response

source

pub(all) struct Response {
  code : Int
  reason : String
  headers : Map[String, String]
  cookies : Array[Cookie]
}

#
Server

source

pub struct Server {
  inner : @moonbitlang/async/http.Server
Server
}

#
Server::accept

source

async fn Server::accept(self : Server) -> (ServerConnection, Addr) raise HttpError

#
Server::addr

source

fn Server::addr(self : Server) -> Addr

#
Server::close

source

fn Server::close(self : Server) -> Unit

#
Server::close_graceful

source

async fn Server::close_graceful(self : Server, timeout_ms? : Int) -> Unit raise HttpError

#
Server::new

source

async fn Server::new(host? : String, port? : Int, headers? : Map[String, String], dual_stack? : Bool, reuse_addr? : Bool, max_request_body_bytes? : Int, request_timeout_ms? : Int, keep_alive_timeout_ms? : Int, headers_timeout_ms? : Int, accept_queue_limit? : Int, trust_proxy? : Bool) -> Server raise HttpError

#
Server::port

source

fn Server::port(self : Server) -> Int

#
Server::run_forever

source

async fn Server::run_forever(self : Server, f : async (Request, &@moonbitlang/async/io.Reader
Reader, ServerConnection) -> Unit, allow_failure? : Bool, max_connections? : Int) -> Unit raise HttpError

#
ServerConnection

source

pub struct ServerConnection {
  inner : @moonbitlang/async/http.ServerConnection
ServerConnection
}

impl Reader for ServerConnection

async fn _direct_read(self : ServerConnection, buf : FixedArray[Byte], offset~ : Int, max_len~ : Int) -> Int

source

fn _get_internal_buffer(self : ServerConnection) -> @moonbitlang/async/io.ReaderBuffer
ReaderBuffer

source

impl Writer for ServerConnection

#
ServerConnection::client_addr

source

fn ServerConnection::client_addr(self : ServerConnection) -> Addr

#
ServerConnection::close

source

fn ServerConnection::close(self : ServerConnection) -> Unit

#
ServerConnection::end_response

source

async fn ServerConnection::end_response(self : ServerConnection) -> Unit raise HttpError

#
ServerConnection::enter_passthrough_mode

source

async fn ServerConnection::enter_passthrough_mode(self : ServerConnection) -> Unit raise HttpError

#
ServerConnection::flush

source

async fn ServerConnection::flush(self : ServerConnection) -> Unit raise HttpError

#
ServerConnection::read_request

source

async fn ServerConnection::read_request(self : ServerConnection) -> Request raise HttpError

#
ServerConnection::send_response

source

async fn ServerConnection::send_response(self : ServerConnection, code : Int, reason : String, extra_headers? : Map[String, String], cookies? : Array[Cookie]) -> Unit raise HttpError

#
ServerConnection::skip_request_body

source

async fn ServerConnection::skip_request_body(self : ServerConnection) -> Unit raise HttpError

#
Stream

source

pub struct Stream {
  inner : @moonbitlang/async/http.Client
Client
}

#
Stream::close

source

fn Stream::close(self : Stream) -> Unit

#
Stream::read_all

source

async fn Stream::read_all(self : Stream) -> Bytes raise HttpError

#
Stream::read_some

source

async fn Stream::read_some(self : Stream) -> Bytes? raise HttpError

#
get

source

async fn get(url : String, headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data, proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

#
get_stream

source

async fn get_stream(url : String, headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data, proxy? : Client) -> (Response, Client) raise HttpError

#
post

source

async fn post(url : String, body : &@moonbitlang/async/io.Data
Data, headers? : Map[String, String], proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

#
post_stream

source

async fn post_stream(url : String, headers? : Map[String, String], proxy? : Client) -> Client raise HttpError

#
put

source

async fn put(url : String, body : &@moonbitlang/async/io.Data
Data, headers? : Map[String, String], proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

#
put_stream

source

async fn put_stream(url : String, headers? : Map[String, String], proxy? : Client) -> Client raise HttpError

Source Files

Install

moon add mizchi/x@0.5.3

Download zip

Node.js backend compatibility layer for moonbitlang/async in MoonBit, with native delegation and JS FFI implementations for process, fs, http, gzip, tls, socket, raw_fd, signal, sync primitives, websocket, stdio, pipe, and sys.

moonbitasyncbackendcompatibilitynodejsprocessfilesystemhttpgziptlssockettcpudpsignalraw-fdqueuesemaphorewebsocketwasi

mizchi

0.5.3

Apache-2.0

github.com/mizchi/x

Updated 19 hours ago

186K downloads

Dependencies

Site source Report issue Packages Build queue Skills Statistics

#HttpError

#Addr

#Client

#Client::close

#Client::end_request

#Client::enter_passthrough_mode

#Client::flush

#Client::get

#Client::new

#Client::post

#Client::put

#Client::request

#Client::skip_response_body

#Cookie

#Cookie::Cookie

#Request

#RequestMethod

#Response

#Server

#Server::accept

#Server::addr

#Server::close

#Server::close_graceful

#Server::new

#Server::port

#Server::run_forever

#ServerConnection

#ServerConnection::client_addr

#ServerConnection::close

#ServerConnection::end_response

#ServerConnection::enter_passthrough_mode

#ServerConnection::flush

#ServerConnection::read_request

#ServerConnection::send_response

#ServerConnection::skip_request_body

#Stream

#Stream::close

#Stream::read_all

#Stream::read_some

#get

#get_stream

#post

#post_stream

#put

#put_stream

Source Files

#
HttpError

#
Addr

#
Client

#
Client::close

#
Client::end_request

#
Client::enter_passthrough_mode

#
Client::flush

#
Client::get

#
Client::new

#
Client::post

#
Client::put

#
Client::request

#
Client::skip_response_body

#
Cookie

#
Cookie::Cookie

#
Request

#
RequestMethod

#
Response

#
Server

#
Server::accept

#
Server::addr

#
Server::close

#
Server::close_graceful

#
Server::new

#
Server::port

#
Server::run_forever

#
ServerConnection

#
ServerConnection::client_addr

#
ServerConnection::close

#
ServerConnection::end_response

#
ServerConnection::enter_passthrough_mode

#
ServerConnection::flush

#
ServerConnection::read_request

#
ServerConnection::send_response

#
ServerConnection::skip_request_body

#
Stream

#
Stream::close

#
Stream::read_all

#
Stream::read_some

#
get

#
get_stream

#
post

#
post_stream

#
put

#
put_stream