necoherence_http_adapter
Types
pub type AdapterPorts {
AdapterPorts(
clock: MonotonicClockPort,
cancellation: CancellationPort,
)
}
Constructors
-
AdapterPorts( clock: MonotonicClockPort, cancellation: CancellationPort, )
pub type CancellationPort {
CancellationPort(
request: fn(network_effect.CancellationCapability) -> Bool,
)
}
Constructors
-
CancellationPort( request: fn(network_effect.CancellationCapability) -> Bool, )
Execution
opaquepub opaque type Execution
pub type MonotonicClockPort {
MonotonicClockPort(
observe: fn() -> network_effect.MonotonicClockObservation,
)
}
Constructors
-
MonotonicClockPort( observe: fn() -> network_effect.MonotonicClockObservation, )
pub type RunOutcome {
Completed
ResponseBodyTruncated
ClosedBeforeHeaders
MalformedResponse
Unclassified
}
Constructors
-
Completed -
ResponseBodyTruncated -
ClosedBeforeHeaders -
MalformedResponse -
Unclassified
pub type StartResult {
Started(Execution)
StartFailed(
network_effect.NetworkHostFailure,
network_effect.EffectStatus,
)
}
Constructors
-
Started(Execution) -
StartFailed( network_effect.NetworkHostFailure, network_effect.EffectStatus, )
Values
pub fn cancel(
execution: Execution,
) -> Result(network_effect.HostObservation, Nil)
pub fn close(
execution: Execution,
) -> Result(network_effect.HostObservation, Nil)
pub fn default_ports() -> AdapterPorts
pub fn handle(
execution: Execution,
) -> network_effect.ExecutionHandle
pub fn host_port(
ports: AdapterPorts,
) -> network_host.AdapterPorts
pub fn observe(
execution: Execution,
) -> Result(network_effect.HostObservation, Nil)
pub fn start(command: network_effect.SendCommand) -> StartResult
pub fn start_with_ports(
command: network_effect.SendCommand,
ports: AdapterPorts,
) -> StartResult