ruststream 0.7.5

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

---
sidebar_position: 6
title: HTTP
description: "An HTTP server owns the process and the service runs beside it: started before the server, stopped after it."
---

import Tabs from '@theme/Tabs';
import TabItem from '@theme/TabItem';

# HTTP

An HTTP server owns the process and the service runs beside it: started before the server, stopped after it.

The service starts with [`start`](./start.md) before the server accepts traffic, so a startup failure stops the process early.
[`publisher`](api:ruststream::runtime::RunningApp::publisher) pairs a bound token with its connected broker, for a task beside the service that publishes.
The example's relay task publishes the orders an HTTP request stored in a transactional outbox.
The server stops on `Ctrl+C`, or when `stopping` reports a fail-fast failure of the service.
The service then drains with [`shutdown`](./shutdown.md).

## Example

<Tabs groupId="api">
<TabItem value="macros" label="Macros">

```rust reference="examples/http_outbox.rs#wiring"
```

</TabItem>
<TabItem value="manual" label="Manual">

```rust reference="examples/manual/http_outbox.rs#wiring"
```

</TabItem>
</Tabs>