mcp_toolkit/transport/sse

Types

RegistryMsg

pub type RegistryMsg {
  Alloc(process.Subject(String))
  Put(String, process.Subject(SseMsg))
  Remove(String)
  Get(
    String,
    process.Subject(option.Option(process.Subject(SseMsg))),
  )
}

Constructors

```
Alloc(process.Subject(String))
```
```
Put(String, process.Subject(SseMsg))
```
```
Remove(String)
```

Get(
  String,
  process.Subject(option.Option(process.Subject(SseMsg))),
)

SseMsg

</>

pub type SseMsg {
  Push(String)
  Stop
}

Constructors

```
Push(String)
```
```
Stop
```

Values

handle_get

</>

pub fn handle_get(
  req: request.Request(@internal Connection),
  registry: process.Subject(RegistryMsg),
) -> response.Response(mist.ResponseData)

handle_post

</>

pub fn handle_post(
  req: request.Request(@internal Connection),
  registry: process.Subject(RegistryMsg),
  srv: server.Server,
) -> response.Response(mist.ResponseData)

handle_sse

</>

pub fn handle_sse(
  req: request.Request(@internal Connection),
  registry: process.Subject(RegistryMsg),
  server: server.Server,
) -> response.Response(mist.ResponseData)

start_registry

</>

pub fn start_registry() -> process.Subject(RegistryMsg)