Experimental support for cancellable RPC requests.

Note: Cancellation should eventually become a feature of the core RPC protocol, and the requests map should be stored in RequestM, or somewhere in the server anyway.

@[reducible, inline]

abbrev ProofWidgets.RequestId : Type

Equations

• ProofWidgets.RequestId = Nat

structure ProofWidgets.CancellableTask : Type

• task : Task (Except Lean.Server.RequestError (ProofWidgets.LazyEncodable Lean.Json))
• cancel : IO Unit

opaque ProofWidgets.runningRequests : IO.Ref (ProofWidgets.RequestId × Lean.HashMap ProofWidgets.RequestId ProofWidgets.CancellableTask)

Maps the ID of each currently executing request to its task.

def ProofWidgets.mkCancellable {β : Type} {α : Sort u_1} [Lean.Server.RpcEncodable β] (handler : α → Lean.Server.RequestM (Lean.Server.RequestTask β)) : α → Lean.Server.RequestM (Lean.Server.RequestTask ProofWidgets.RequestId)

Transforms a request handler returning β into one that returns immediately with a RequestId.

The ID uniquely identifies the running request: its results can be retrieved using checkRequest, and it can be cancelled using cancelRequest.

Equations

• One or more equations did not get rendered due to their size.

def ProofWidgets.cancelRequest (rid : ProofWidgets.RequestId) : Lean.Server.RequestM (Lean.Server.RequestTask String)

Cancel the request with ID rid. Does nothing if rid is invalid.

Equations

• One or more equations did not get rendered due to their size.

inductive ProofWidgets.CheckRequestResponse : Type

The status of a running cancellable request.

• running: ProofWidgets.CheckRequestResponse
• done: ProofWidgets.LazyEncodable Lean.Json → ProofWidgets.CheckRequestResponse

instance ProofWidgets.ProofWidgets.CheckRequestResponse.instToJsonRpcEncodablePacket : Lean.ToJson ProofWidgets.ProofWidgets.CheckRequestResponse.RpcEncodablePacket✝

Equations

• ProofWidgets.ProofWidgets.CheckRequestResponse.instToJsonRpcEncodablePacket = { toJson := ProofWidgets.ProofWidgets.CheckRequestResponse.toJsonRpcEncodablePacket✝ }

instance ProofWidgets.ProofWidgets.CheckRequestResponse.instRpcEncodableCheckRequestResponse : Lean.Server.RpcEncodable ProofWidgets.CheckRequestResponse

Equations

• One or more equations did not get rendered due to their size.

instance ProofWidgets.ProofWidgets.CheckRequestResponse.instFromJsonRpcEncodablePacket : Lean.FromJson ProofWidgets.ProofWidgets.CheckRequestResponse.RpcEncodablePacket✝

Equations

• ProofWidgets.ProofWidgets.CheckRequestResponse.instFromJsonRpcEncodablePacket = { fromJson? := ProofWidgets.ProofWidgets.CheckRequestResponse.fromJsonRpcEncodablePacket✝ }

def ProofWidgets.checkRequest (rid : ProofWidgets.RequestId) : Lean.Server.RequestM (Lean.Server.RequestTask ProofWidgets.CheckRequestResponse)

Check whether a request has finished computing, and return the response if so. The request is removed from runningRequests the first time it is checked and found to have finished. Throws an error if the rid is invalid, or if the request itself threw an error.

Equations

• One or more equations did not get rendered due to their size.

def ProofWidgets.cancellableSuffix : Lean.Name

Equations

• ProofWidgets.cancellableSuffix = `_cancellable