wzzc-dev/moui/backend/common/services

wzzc-dev/moui/backend/common/services does not have a README file

ServiceAsyncQueue

pub struct ServiceAsyncQueue {
  next_value : Int
  pending : Array[@wzzc-dev/moui/backend.HostPendingServiceRequest
HostPendingServiceRequest]
  in_flight : Array[@wzzc-dev/moui/backend.HostPendingServiceRequest
HostPendingServiceRequest]
  completed : Array[@wzzc-dev/moui/backend.HostCompletedServiceResponse
HostCompletedServiceResponse]
  // private fields
}

ServiceAsyncQueue::cancel

source

fn ServiceAsyncQueue::cancel(self : ServiceAsyncQueue, id : @wzzc-dev/moui/backend.HostServiceRequestId
HostServiceRequestId, reason : String) -> Bool

Cancel one outstanding request. Completion is still delivered through the normal exactly-once path so app subscriptions observe the cancellation.

ServiceAsyncQueue::cancel_all

source

fn ServiceAsyncQueue::cancel_all(self : ServiceAsyncQueue) -> Int

Drop every outstanding request and completion handler during host teardown. Subsequent completions are rejected because their request ids no longer exist in either pending or in-flight state.

ServiceAsyncQueue::complete

source

fn ServiceAsyncQueue::complete(self : ServiceAsyncQueue, id : @wzzc-dev/moui/backend.HostServiceRequestId
HostServiceRequestId, response : @wzzc-dev/moui/backend.HostServiceResponse
HostServiceResponse) -> Bool

ServiceAsyncQueue::completed_count

source

fn ServiceAsyncQueue::completed_count(self : ServiceAsyncQueue) -> Int

ServiceAsyncQueue::drain_completed

source

fn ServiceAsyncQueue::drain_completed(self : ServiceAsyncQueue) -> Array[@wzzc-dev/moui/backend.HostCompletedServiceResponse
HostCompletedServiceResponse]

ServiceAsyncQueue::drain_pending

source

fn ServiceAsyncQueue::drain_pending(self : ServiceAsyncQueue) -> Array[@wzzc-dev/moui/backend.HostPendingServiceRequest
HostPendingServiceRequest]

ServiceAsyncQueue::in_flight_count

source

fn ServiceAsyncQueue::in_flight_count(self : ServiceAsyncQueue) -> Int

ServiceAsyncQueue::new

source

fn ServiceAsyncQueue::new() -> ServiceAsyncQueue

ServiceAsyncQueue::on_completed

source

fn ServiceAsyncQueue::on_completed(self : ServiceAsyncQueue, id : @wzzc-dev/moui/backend.HostServiceRequestId
HostServiceRequestId, handle : (@wzzc-dev/moui/backend.HostCompletedServiceResponse
HostCompletedServiceResponse) -> Unit) -> Bool

ServiceAsyncQueue::outstanding_count

source

fn ServiceAsyncQueue::outstanding_count(self : ServiceAsyncQueue) -> Int

ServiceAsyncQueue::pending_count

source

fn ServiceAsyncQueue::pending_count(self : ServiceAsyncQueue) -> Int

ServiceAsyncQueue::reject

source

fn ServiceAsyncQueue::reject(self : ServiceAsyncQueue, id : @wzzc-dev/moui/backend.HostServiceRequestId
HostServiceRequestId, reason : String) -> Bool

ServiceAsyncQueue::submit

source

fn ServiceAsyncQueue::submit(self : ServiceAsyncQueue, request : @wzzc-dev/moui/backend.HostServiceRequest
HostServiceRequest) -> @wzzc-dev/moui/backend.HostServiceResponse
HostServiceResponse

ServiceAsyncQueue::take_completed

source

fn ServiceAsyncQueue::take_completed(self : ServiceAsyncQueue, id : @wzzc-dev/moui/backend.HostServiceRequestId
HostServiceRequestId) -> @wzzc-dev/moui/backend.HostCompletedServiceResponse
HostCompletedServiceResponse?

WindowServiceState

source

pub struct WindowServiceState {
  // private fields
}

Host service bridge lifetime owner. Backends keep this owner directly so callbacks can be rejected after the service channel has been closed.

WindowServiceState::bridge

source

fn WindowServiceState::bridge(self : WindowServiceState) -> @wzzc-dev/moui/backend.HostServiceBridge
HostServiceBridge

WindowServiceState::dispose

source

fn WindowServiceState::dispose(self : WindowServiceState) -> Unit

WindowServiceState::is_open

source

fn WindowServiceState::is_open(self : WindowServiceState) -> Bool

WindowServiceState::new

source

fn WindowServiceState::new(bridge~ : @wzzc-dev/moui/backend.HostServiceBridge
HostServiceBridge, dispose? : () -> Unit) -> WindowServiceState

app_environment

source

fn app_environment(bridge~ : @wzzc-dev/moui/backend.HostServiceBridge
HostServiceBridge, async_queue? : ServiceAsyncQueue?, timer? : @wzzc-dev/moui/services.TimerSource
TimerSource?, routes? : @wzzc-dev/moui/services.RouteSource
RouteSource?, lifecycle? : @wzzc-dev/moui/services.AppLifecycleSource
AppLifecycleSource?, clock? : () -> Double?, window_drag? : @wzzc-dev/moui/services.WindowDragRegionSource
WindowDragRegionSource?) -> @wzzc-dev/moui/services.AppEnvironment
AppEnvironment

Build the app-facing environment supplied to a Program closure.

app_services

source

fn app_services(bridge~ : @wzzc-dev/moui/backend.HostServiceBridge
HostServiceBridge, async_queue? : ServiceAsyncQueue?, lifecycle? : @wzzc-dev/moui/services.AppLifecycleSource
AppLifecycleSource?, window_drag? : @wzzc-dev/moui/services.WindowDragRegionSource
WindowDragRegionSource?) -> @wzzc-dev/moui/services.AppServices
AppServices

Adapt the host wire protocol to the typed app-facing services boundary. Request ids and completion queues remain private to this package.

Source Files

Site source Report issue Packages Build queue Skills Statistics

#ServiceAsyncQueue

#ServiceAsyncQueue::cancel

#ServiceAsyncQueue::cancel_all

#ServiceAsyncQueue::complete

#ServiceAsyncQueue::completed_count

#ServiceAsyncQueue::drain_completed

#ServiceAsyncQueue::drain_pending

#ServiceAsyncQueue::in_flight_count

#ServiceAsyncQueue::new

#ServiceAsyncQueue::on_completed

#ServiceAsyncQueue::outstanding_count

#ServiceAsyncQueue::pending_count

#ServiceAsyncQueue::reject

#ServiceAsyncQueue::submit

#ServiceAsyncQueue::take_completed

#WindowServiceState

#WindowServiceState::bridge

#WindowServiceState::dispose

#WindowServiceState::is_open

#WindowServiceState::new

#app_environment

#app_services

Source Files

ServiceAsyncQueue

ServiceAsyncQueue::cancel

ServiceAsyncQueue::cancel_all

ServiceAsyncQueue::complete

ServiceAsyncQueue::completed_count

ServiceAsyncQueue::drain_completed

ServiceAsyncQueue::drain_pending

ServiceAsyncQueue::in_flight_count

ServiceAsyncQueue::new

ServiceAsyncQueue::on_completed

ServiceAsyncQueue::outstanding_count

ServiceAsyncQueue::pending_count

ServiceAsyncQueue::reject

ServiceAsyncQueue::submit

ServiceAsyncQueue::take_completed

WindowServiceState

WindowServiceState::bridge

WindowServiceState::dispose

WindowServiceState::is_open

WindowServiceState::new

app_environment

app_services