README
U
ErrorHandler
U
HttpHandler
U
Middleware
U
MiddlewareNext
U
WebSocketHandler
Tr
BodyReader
Tr
Responder
Tr
ServeStaticProvider
E
ExecError
E
FormDataError
E
IOError
E
NetworkError
- ::AppApp::App
- ::aclApp::acl
- ::allApp::all
- ::bindApp::bind
- ::checkinApp::checkin
- ::checkoutApp::checkout
- ::connectApp::connect
- ::copyApp::copy
- ::deleteApp::delete
- ::getApp::get
- ::groupApp::group
- ::headApp::head
- ::labelApp::label
- ::linkApp::link
- ::listenApp::listen
- ::lockApp::lock
- ::mergeApp::merge
- ::mkactivityApp::mkactivity
- ::mkcalendarApp::mkcalendar
- ::mkcolApp::mkcol
- ::mkredirectrefApp::mkredirectref
- ::mkworkspaceApp::mkworkspace
- ::move_App::move_
- ::onApp::on
- ::on_errorApp::on_error
- ::optionsApp::options
- ::orderpatchApp::orderpatch
- ::patchApp::patch
- ::postApp::post
- ::priApp::pri
- ::propfindApp::propfind
- ::proppatchApp::proppatch
- ::putApp::put
- ::queryApp::query
- ::rebindApp::rebind
- ::reportApp::report
- ::searchApp::search
- ::serveApp::serve
- ::static_assetsApp::static_assets
- ::traceApp::trace
- ::unbindApp::unbind
- ::uncheckoutApp::uncheckout
- ::unlinkApp::unlink
- ::unlockApp::unlock
- ::updateApp::update
- ::updateredirectrefApp::updateredirectref
- ::use_middlewareApp::use_middleware
- ::version_controlApp::version_control
- ::wsApp::ws
- ::fieldsFormData::fields
- ::getFormData::get
- ::newFormData::new
T
Html
- ::bodyHttpRequest::body
- ::get_cookieHttpRequest::get_cookie
- ::jsonHttpRequest::json
- ::queryHttpRequest::query
- ::HttpResponseHttpResponse::HttpResponse
- ::bodyHttpResponse::body
- ::delete_cookieHttpResponse::delete_cookie
- ::jsonHttpResponse::json
- ::read_bodyHttpResponse::read_body
- ::set_cookieHttpResponse::set_cookie
- ::to_responderHttpResponse::to_responder
- ::bodyMocketEvent::body
T
MultipartFormValue
- ::bytesResponseBuffer::bytes
- ::newResponseBuffer::new
- ::newStaticAssetMeta::new
- ::from_intStatusCode::from_int
- ::to_intStatusCode::to_int
T
WebSocketAggregatedMessage
T
WebSocketEvent
- ::binaryWebSocketPeer::binary
- ::pongWebSocketPeer::pong
- ::publishWebSocketPeer::publish
- ::subscribeWebSocketPeer::subscribe
- ::textWebSocketPeer::text
- ::to_stringWebSocketPeer::to_string
- ::unsubscribeWebSocketPeer::unsubscribe
V
__ws_emit
V
dispatch_http
V
dispatch_ws_event
V
escape_html
V
execute_middlewares
V
form_encode
V
handle_not_found
V
html
V
listen_ffi
V
new
V
parse_form_data
V
parse_query
V
parse_request_cookie
V
register_ws_connection
V
register_ws_handler
V
serialize_cookie
V
serve_ffi
V
suspend
V
text
V
unregister_ws_connection
V
url_decode
V
url_encode
V
ws_pong
V
ws_publish
V
ws_send
V
ws_send_bytes
V
ws_subscribe
V
ws_unsubscribe

mocket

A web framework for MoonBit.

http

server

Download zip

Author

oboard

Version

0.10.0

License

Apache-2.0

Repository

github.com/oboard/mocket

Last updated

1 hour ago

Downloads

Dependencies

#oboard/mocket

A web framework for MoonBit.

👉 Documentation

#Quick Start

async fn main {
  let app = @mocket.App()
  app.get("/", _ => "Hello, Mocket!")
  app.listen(":80")
}

Mocket supports both js and native backends.

#JavaScript Backend

Set the backend of MoonBit to js in Visual Studio Code

Command: MoonBit: Select Backend -> js

moon run src/example --target js

#Native Backend

Set the backend of MoonBit to native in Visual Studio Code

Command: MoonBit: Select Backend -> native

moon run src/example --target native

Then visit http://localhost:4000

#Usage

Minimum Example: https://github.com/oboard/mocket_example

🙌快来吧！🙌

QQ 群号：949886784

ErrorHandler

source

type ErrorHandler = (MocketEvent, Error) -> &Responder

HttpHandler

source

type HttpHandler = async (MocketEvent) -> &Responder

Middleware

source

type Middleware = async (MocketEvent, async () -> &Responder) -> &Responder

MiddlewareNext

source

type MiddlewareNext = async () -> &Responder

WebSocketHandler

source

type WebSocketHandler = (WebSocketEvent) -> Unit

BodyReader

source

pub(open) trait BodyReader {
  async fn from_request(req : HttpRequest) -> Self
}

impl BodyReader for String

impl BodyReader for FixedArray[Byte]

impl BodyReader for Bytes

impl BodyReader for Array[Byte]

impl BodyReader for Json

Responder

source

pub(open) trait Responder {
  fn options(Self, res : HttpResponse) -> Unit
  async fn output(Self, writer : &@moonbitlang/async/io.Writer
Writer) -> Unit
}

impl Responder for String

impl Responder for Bytes

impl Responder for Json

impl Responder for ToJson

impl Responder for StringView

ServeStaticProvider

source

pub(open) trait ServeStaticProvider {
  async fn get_meta(Self, id : StringView) -> StaticAssetMeta?
  async fn get_contents(Self, id : StringView) -> &Responder
  fn get_type(Self, ext : String) -> String?
  fn get_encodings(Self) -> Map[String, String]
  fn get_index_names(Self) -> Array[String]
  fn get_fallthrough(Self) -> Bool
}

A backend for Mocket::static_assets.

Asset ids handed to the provider are virtual absolute paths rooted at the mount point: they always start with "/" and are already normalized, so "." / ".." segments can never escape the provider's root. Providers should join the id onto their root directly.

ExecError

source

pub suberror ExecError

FormDataError

source

pub suberror FormDataError {
  MissingContentType
  InvalidContentType(String)
  UnsupportedContentType(String)
  MissingBoundary
}

Errors raised while decoding a multipart/form-data request body.

IOError

source

pub suberror IOError

NetworkError

source

pub suberror NetworkError

App

source

#alias(Mocket)
#alias(T)
pub(all) struct App {
  base_path : String
  mappings : Map[(String, String), async (MocketEvent) -> &Responder]
  middlewares : Array[(String, async (MocketEvent, async () -> &Responder) -> &Responder)]
  static_routes : Map[String, Map[String, async (MocketEvent) -> &Responder]]
  dynamic_routes : Map[String, Array[(String, async (MocketEvent) -> &Responder)]]
  ws_static_routes : Map[String, (WebSocketEvent) -> Unit]
  ws_dynamic_routes : Array[(String, (WebSocketEvent) -> Unit)]
  ws_clients : Map[String, Unit]
  ws_channels : Map[String, Map[String, Unit]]
  ws_client_port : Map[String, Int]
  max_body_size : Int
  error_handler : (MocketEvent, Error) -> &Responder
  // private fields
}

App::App

source

#alias(new, deprecated="Use `App()` instead")
fn App::App(base_path? : String, max_body_size? : Int) -> App

App::acl

source

fn App::acl(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::all

source

fn App::all(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::bind

source

fn App::bind(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::checkin

source

fn App::checkin(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::checkout

source

fn App::checkout(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::connect

source

fn App::connect(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::copy

source

fn App::copy(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::delete

source

fn App::delete(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::get

source

fn App::get(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::group

source

fn App::group(self : App, base_path : String, configure : (App) -> Unit) -> Unit

App::head

source

fn App::head(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::label

source

fn App::label(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::link

source

fn App::link(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::listen

source

async fn App::listen(self : App, address : String) -> Unit noraise

App::lock

source

fn App::lock(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::merge

source

fn App::merge(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::mkactivity

source

fn App::mkactivity(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::mkcalendar

source

fn App::mkcalendar(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::mkcol

source

fn App::mkcol(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::mkredirectref

source

fn App::mkredirectref(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::mkworkspace

source

fn App::mkworkspace(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::move_

source

fn App::move_(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::on

source

fn App::on(self : App, event : String, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::on_error

source

fn App::on_error(self : App, handler : (MocketEvent, Error) -> &Responder) -> Unit

App::options

source

fn App::options(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::orderpatch

source

fn App::orderpatch(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::patch

source

fn App::patch(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::post

source

fn App::post(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::pri

source

fn App::pri(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::propfind

source

fn App::propfind(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::proppatch

source

fn App::proppatch(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::put

source

fn App::put(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::query

source

fn App::query(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::rebind

source

fn App::rebind(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::report

source

fn App::report(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::search

source

fn App::search(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::serve

source

#deprecated("use `Mocket::listen(address)` instead")
async fn App::serve(self : App, port~ : Int) -> Unit noraise

App::static_assets

source

fn App::static_assets(self : App, path : String, provider : &ServeStaticProvider) -> Unit

App::trace

source

fn App::trace(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::unbind

source

fn App::unbind(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::uncheckout

source

fn App::uncheckout(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::unlink

source

fn App::unlink(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::unlock

source

fn App::unlock(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::update

source

fn App::update(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::updateredirectref

source

fn App::updateredirectref(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::use_middleware

source

fn App::use_middleware(self : App, middleware : async (MocketEvent, async () -> &Responder) -> &Responder, base_path? : String) -> Unit

App::version_control

source

fn App::version_control(self : App, path : String, handler : async (MocketEvent) -> &Responder) -> Unit

App::ws

source

fn App::ws(self : App, path : String, handler : (WebSocketEvent) -> Unit) -> Unit

FormData

source

pub(all) struct FormData {
  fields : Map[String, MultipartFormValue]
  response_boundary : String?
}

A parsed multipart/form-data request body.

Each form field is indexed by name. Text fields and uploaded files both use MultipartFormValue; an upload has a filename, while a normal text field does not.

impl BodyReader for FormData

async fn from_request(req : HttpRequest) -> FormData

source

Decodes a multipart/form-data request, including its boundary parameter.

The request must include a Content-Type: multipart/form-data; boundary=… header. Parsed file data remains in memory as BytesView.

impl Responder for FormData

FormData::fields

source

fn FormData::fields(self : FormData) -> Map[String, MultipartFormValue]

Returns all parsed form fields. For duplicate field names, the final value in the multipart body is retained.

FormData::get

source

fn FormData::get(self : FormData, name : String) -> MultipartFormValue?

Looks up a form field or uploaded file by its field name.

FormData::new

source

fn FormData::new(fields : Map[String, MultipartFormValue]) -> FormData

Creates multipart form data for use as a request body or response body.

Html

source

type Html

impl Responder for Html

HttpRequest

source

pub(all) struct HttpRequest {
  http_method : String
  url : String
  query : String
  headers : Map[@moonbitlang/async/http.CaseInsensitiveString
CaseInsensitiveString, StringView]
  reader : &@moonbitlang/async/io.Reader
Reader
}

HttpRequest::body

source

async fn[T : BodyReader] HttpRequest::body(self : HttpRequest) -> T

Decode the request body with T. On native HTTP requests this consumes the network body incrementally when the selected BodyReader supports it.

HttpRequest::get_cookie

source

fn HttpRequest::get_cookie(self : HttpRequest, name : String) -> @moonbitlang/async/http.Cookie
Cookie?

Looks up a cookie from a request's Cookie header.

HttpRequest::json

source

async fn[T : @moonbitlang/core/json.FromJson
FromJson] HttpRequest::json(self : HttpRequest) -> T

HttpRequest::query

source

fn HttpRequest::query(self : HttpRequest) -> Map[String, String]

HttpResponse

source

pub(all) struct HttpResponse {
  status_code : StatusCode
  headers : Map[@moonbitlang/async/http.CaseInsensitiveString
CaseInsensitiveString, StringView]
  cookies : Array[@moonbitlang/async/http.Cookie
Cookie]
  body : &Responder?
}

impl Responder for HttpResponse

HttpResponse::HttpResponse

source

#alias(new, deprecated="Use `HttpResponse()` instead")
fn HttpResponse::HttpResponse(status_code : StatusCode, headers? : Map[@moonbitlang/async/http.CaseInsensitiveString
CaseInsensitiveString, StringView], cookies? : Array[@moonbitlang/async/http.Cookie
Cookie], body? : &Responder) -> HttpResponse

HttpResponse::body

source

fn HttpResponse::body(self : HttpResponse, body : &Responder) -> HttpResponse

Sets the response body from any Responder.

The body responder's default Content-Type is carried into this response only when no explicit "Content-Type" header was set on this response. Explicit response headers always take precedence.

Only the default Content-Type is inferred. The responder's status, other headers, cookies, and any other responder effects are not merged, so self.status_code is preserved.

HttpResponse::delete_cookie

source

fn HttpResponse::delete_cookie(self : HttpResponse, key : String) -> Unit

HttpResponse::json

source

fn HttpResponse::json(self : HttpResponse, obj : &ToJson) -> HttpResponse

Sets a JSON response body.

Infers Content-Type: application/json; charset=utf-8 under the same rule as HttpResponse::body: an explicit "Content-Type" header already present on this response takes precedence, and self.status_code is preserved.

HttpResponse::read_body

source

async fn[T : BodyReader] HttpResponse::read_body(self : HttpResponse) -> T

HttpResponse::set_cookie

source

fn HttpResponse::set_cookie(self : HttpResponse, cookie : @moonbitlang/async/http.Cookie
Cookie) -> Unit

Adds an async HTTP runtime cookie as a Set-Cookie entry.

HttpResponse::to_responder

source

fn HttpResponse::to_responder(self : HttpResponse) -> &Responder

MocketEvent

source

pub(all) struct MocketEvent {
  req : HttpRequest
  res : HttpResponse
  params : Map[String, StringView]
}

MocketEvent::body

source

async fn[T : BodyReader] MocketEvent::body(self : MocketEvent) -> T

MultipartFormValue

source

pub(all) struct MultipartFormValue {
  filename : String?
  content_type : String?
  data : BytesView
}

ResponseBuffer

source

pub(all) struct ResponseBuffer {
  buffer : @moonbitlang/core/buffer.Buffer
Buffer
}

Buffers output written through @io.Writer for backends that require a complete byte slice before they can send a response.

impl Writer for ResponseBuffer

async fn write(self : ResponseBuffer, data : &@moonbitlang/async/io.Data
Data) -> Unit

source

async fn write_once(self : ResponseBuffer, bytes : Bytes, offset~ : Int, len~ : Int) -> Int

source

async fn write_reader(self : ResponseBuffer, reader : &@moonbitlang/async/io.Reader
Reader) -> Unit

source

ResponseBuffer::bytes

source

fn ResponseBuffer::bytes(self : ResponseBuffer) -> Bytes

ResponseBuffer::new

source

fn ResponseBuffer::new() -> ResponseBuffer

StaticAssetMeta

source

pub(all) struct StaticAssetMeta {
  asset_type : String?
  etag : String?
  mtime : Int64?
  path : String?
  size : Int64?
  encoding : String?
}

StaticAssetMeta::new

source

fn StaticAssetMeta::new(asset_type? : String, etag? : String, mtime? : Int64, path? : String, size? : Int64, encoding? : String) -> StaticAssetMeta

StatusCode

source

pub(all) enum StatusCode {
  Continue
  SwitchingProtocols
  Processing
  EarlyHints
  OK
  Created
  Accepted
  NonAuthoritativeInfo
  NoContent
  ResetContent
  PartialContent
  MultiStatus
  AlreadyReported
  IMUsed
  MultipleChoices
  MovedPermanently
  Found
  SeeOther
  NotModified
  UseProxy
  TemporaryRedirect
  PermanentRedirect
  BadRequest
  Unauthorized
  PaymentRequired
  Forbidden
  NotFound
  MethodNotAllowed
  NotAcceptable
  ProxyAuthRequired
  RequestTimeout
  Conflict
  Gone
  LengthRequired
  PreconditionFailed
  RequestEntityTooLarge
  RequestUriTooLong
  UnsupportedMediaType
  RequestedRangeNotSatisfiable
  ExpectationFailed
  Teapot
  MisdirectedRequest
  UnprocessableEntity
  Locked
  FailedDependency
  TooEarly
  UpgradeRequired
  PreconditionRequired
  TooManyRequests
  RequestHeaderFieldsTooLarge
  UnavailableForLegalReasons
  InternalServerError
  NotImplemented
  BadGateway
  ServiceUnavailable
  GatewayTimeout
  HttpVersionNotSupported
  VariantAlsoNegotiates
  InsufficientStorage
  LoopDetected
  NotExtended
  NetworkAuthenticationRequired
  Custom(Int)
} derive(Eq, ToJson)

HTTP status codes as registered with IANA. See: https://www.iana.org/assignments/http-status-codes/http-status-codes.xhtml

StatusCode::from_int

source

fn StatusCode::from_int(i : Int) -> StatusCode

StatusCode::to_int

source

fn StatusCode::to_int(self : StatusCode) -> Int

WebSocketAggregatedMessage

source

pub(all) enum WebSocketAggregatedMessage {
  Text(String)
  Binary(Bytes)
  Ping
}

WebSocketEvent

source

pub(all) enum WebSocketEvent {
  Open(WebSocketPeer)
  Message(WebSocketPeer, WebSocketAggregatedMessage)
  Close(WebSocketPeer)
}

WebSocketPeer

source

pub(all) struct WebSocketPeer {
  connection_id : String
  subscribed_channels : Array[String]
}

WebSocketPeer::binary

source

fn WebSocketPeer::binary(self : WebSocketPeer, message : Bytes) -> Unit

WebSocketPeer::pong

source

fn WebSocketPeer::pong(self : WebSocketPeer) -> Unit

WebSocketPeer::publish

source

fn WebSocketPeer::publish(channel : String, message : String) -> Unit

fn WebSocketPeer::subscribe(self : WebSocketPeer, channel : String) -> Unit

WebSocketPeer::text

source

fn WebSocketPeer::text(self : WebSocketPeer, message : String) -> Unit

WebSocketPeer::to_string

source

fn WebSocketPeer::to_string(self : WebSocketPeer) -> String

WebSocketPeer::unsubscribe

source

fn WebSocketPeer::unsubscribe(self : WebSocketPeer, channel : String) -> Unit

__ws_emit

source

fn __ws_emit(event_type : Bytes, connection_id : Bytes, payload : Bytes) -> Unit

dispatch_http

source

async fn dispatch_http(mocket : App, http_method : String, url : String, headers : Map[@moonbitlang/async/http.CaseInsensitiveString
CaseInsensitiveString, StringView], body : Bytes) -> HttpResponse

dispatch_ws_event

source

fn dispatch_ws_event(handler : (WebSocketEvent) -> Unit, peer : WebSocketPeer, event_type : String, payload : Bytes) -> Unit

将 WS 事件类型字符串和 payload 转换为 WebSocketEvent 并调用 handler

escape_html

source

fn escape_html(s : String) -> String

execute_middlewares

source

async fn execute_middlewares(middlewares : Array[(String, async (MocketEvent, async () -> &Responder) -> &Responder)], event : MocketEvent, final_handler : async (MocketEvent) -> &Responder) -> &Responder

form_encode

source

fn form_encode(map : Map[String, String]) -> String

handle_not_found

source

fn handle_not_found() -> (async (MocketEvent) -> &Responder)

html

source

fn html(html : &Show) -> &Responder

listen_ffi

source

async fn listen_ffi(mocket : App, address : String) -> Unit noraise

Listen and serve on address.

The native listener enables SO_REUSEADDR (reuse_addr=true) so that a process can immediately rebind a port that a previous process left in TIME_WAIT. On macOS/BSD this has the side effect that a bind to a specific address may "steal" the specific interface from an existing wildcard bind (0.0.0.0), and a wildcard bind can bind to the remaining interfaces if a specific-interface bind already exists.

new

source

#deprecated("Use `App()` instead")
fn new(base_path? : String, max_body_size? : Int) -> App

parse_form_data

source

fn parse_form_data(bytes : BytesView) -> Map[String, String]

parse_query

source

fn parse_query(query_string : StringView) -> Map[String, String]

parse_request_cookie

source

fn parse_request_cookie(cookie : StringView) -> Map[String, @moonbitlang/async/http.Cookie
Cookie]

Parses the Cookie request header. Request cookies are name/value pairs; Set-Cookie attributes never apply to this header.

register_ws_connection

source

fn register_ws_connection(connection_id : String, text_sender : (String) -> Unit, binary_sender : (Bytes) -> Unit, pong_sender : () -> Unit) -> Unit

register_ws_handler

source

fn register_ws_handler(mocket : App, port : Int) -> Unit

serialize_cookie

source

fn serialize_cookie(cookie : @moonbitlang/async/http.Cookie
Cookie) -> String

Serializes an async HTTP cookie for non-native backends that need to write Set-Cookie themselves.

serve_ffi

source

async fn serve_ffi(mocket : App, port~ : Int) -> Unit noraise

suspend

source

async fn[T, E : Error] suspend(f : ((T) -> Unit, (E) -> Unit) -> Unit) -> T raise E

suspend 会中断当前协程的运行。 suspend 会接受一个回调函数，并让这个回调函数来操作中断的协程

text

source

fn text(text : &Show) -> &Responder

unregister_ws_connection

source

fn unregister_ws_connection(connection_id : String) -> Unit

url_decode

source

fn url_decode(bytes : BytesView) -> String

url_encode

source

fn url_encode(s : String) -> String

ws_pong

source

fn ws_pong(id : String) -> Unit

ws_publish

source

fn ws_publish(channel : String, msg : String) -> Unit

ws_send

source

fn ws_send(id : String, msg : String) -> Unit

ws_send_bytes

source

fn ws_send_bytes(id : String, msg : Bytes) -> Unit

ws_subscribe

source

fn ws_subscribe(id : String, channel : String) -> Unit

ws_unsubscribe

source

fn ws_unsubscribe(id : String, channel : String) -> Unit

Site source Report issue Packages Build queue Skills Statistics

mocket

#oboard/mocket

#Quick Start

#JavaScript Backend

#Native Backend

#Usage

#ErrorHandler

#HttpHandler

#Middleware

#MiddlewareNext

#WebSocketHandler

#BodyReader

#Responder

#ServeStaticProvider

#ExecError

#FormDataError

#IOError

#NetworkError

#App

#App::App

#App::acl

#App::all

#App::bind

#App::checkin

#App::checkout

#App::connect

#App::copy

#App::delete

#App::get

#App::group

#App::head

#App::label

#App::link

#App::listen

#App::lock

#App::merge

#App::mkactivity

#App::mkcalendar

#App::mkcol

#App::mkredirectref

#App::mkworkspace

#App::move_

#App::on

#App::on_error

#App::options

#App::orderpatch

#App::patch

#App::post

#App::pri

#App::propfind

#App::proppatch

#App::put

#App::query

#App::rebind

#App::report

#App::search

#App::serve

#App::static_assets

#App::trace

#App::unbind

#App::uncheckout

#App::unlink

#App::unlock

#App::update

#App::updateredirectref

#App::use_middleware

#App::version_control

#App::ws

#FormData

#FormData::fields

#FormData::get

#FormData::new

#Html

#HttpRequest

#HttpRequest::body

#HttpRequest::get_cookie

#HttpRequest::json

#HttpRequest::query

#HttpResponse

#HttpResponse::HttpResponse

ErrorHandler

HttpHandler

Middleware

MiddlewareNext

WebSocketHandler

BodyReader

Responder

ServeStaticProvider

ExecError

FormDataError

IOError

NetworkError

App

App::App

App::acl

App::all

App::bind

App::checkin

App::checkout

App::connect

App::copy

App::delete

App::get

App::group

App::head

App::label

App::link

App::listen

App::lock

App::merge

App::mkactivity

App::mkcalendar

App::mkcol

App::mkredirectref

App::mkworkspace

App::move_

App::on

App::on_error

App::options

App::orderpatch

App::patch

App::post

App::pri

App::propfind

App::proppatch

App::put

App::query

App::rebind

App::report

App::search

App::serve

App::static_assets

App::trace

App::unbind

App::uncheckout

App::unlink

App::unlock

App::update

App::updateredirectref

App::use_middleware

App::version_control

App::ws

FormData

FormData::fields

FormData::get

FormData::new

Html

HttpRequest

HttpRequest::body

HttpRequest::get_cookie

HttpRequest::json

HttpRequest::query

HttpResponse

HttpResponse::HttpResponse

HttpResponse::body

HttpResponse::delete_cookie

HttpResponse::json

HttpResponse::read_body

HttpResponse::set_cookie

HttpResponse::to_responder