#Proton Rabbita

justjavac/proton_rabbita maps typed Proton commands and events onto Rabbita Cmd and Sub values. Transport and JSON handling remain owned by justjavac/proton_client.

///|
struct PingRequest {
  value : String
} derive(ToJson)

///|
struct PingReply {
  value : String
} derive(FromJson)

///|
test {
  let ping : @proton_contract.Command[PingRequest, PingReply] = @proton_contract.command(
    "ping",
  )
  let request = PingRequest::{ value: "hello" }
  let command = invoke(
    ping,
    request,
    reply => {
      ignore(reply.value)
      @cmd.none
    },
    _error => @cmd.none,
  )
  ignore(command)
}

An event subscription installation failure is reported through its failure callback once. Rabbita retains a terminal subscription for that key instead of retrying after every model update, which prevents a failure-message feedback loop. To retry explicitly, omit the subscription for one update and then add it again. The Proton bridge is expected to be available before application frontend code starts.

#
invoke

source

fn[Request : ToJson, Response : @moonbitlang/core/json.FromJson
FromJson] invoke(command : @justjavac/proton_contract.Command
Command[Request, Response], request : Request, success : (Response) -> @moonbit-community/rabbita/cmd.Cmd
Cmd, failure : (@justjavac/proton_client.ClientFailure
ClientFailure) -> @moonbit-community/rabbita/cmd.Cmd
Cmd) -> @moonbit-community/rabbita/cmd.Cmd
Cmd

Invokes a typed Proton command as one Rabbita command.

Success and failure are separate callbacks so application messages do not need to expose transport-oriented Result values.

fn[Payload : @moonbitlang/core/json.FromJson
FromJson] subscribe(event : @justjavac/proton_contract.Event
Event[Payload], received : (Payload) -> @moonbit-community/rabbita/cmd.Cmd
Cmd, failure : (@justjavac/proton_client.ClientFailure
ClientFailure) -> @moonbit-community/rabbita/cmd.Cmd
Cmd) -> @moonbit-community/rabbita/sub.Sub
Sub

Subscribes to one typed Proton event as a stable Rabbita subscription.

Recomputing the subscription updates its taggers without reinstalling the renderer listener. A malformed event reports one failure and leaves the subscription active.

An initial installation failure is reported once and retained as a terminal subscription for that key. This prevents the failure message from causing an immediate retry loop. Remove the subscription for one update and add it again to retry explicitly.

Source Files

adapter.mbt

Site source Report issue Packages Build queue Skills Statistics

proton_rabbita

#Proton Rabbita

#invoke

#subscribe

Source Files

#
invoke

#
subscribe