sprocket/cassette

Types

Cassette

pub type Cassette =
  Subject(Message)

Message

</>

pub type Message {
  Shutdown
  GetState(reply_with: Subject(Result(State, Nil)))
  PushPreflight(preflight: Preflight)
  CleanupPreflights
  StartPreflightCleanupJob(cleanup_preflights: fn() -> Nil)
  PopPreflight(
    reply_with: Subject(Result(Preflight, Nil)),
    id: String,
  )
  PushSprocket(sprocket: Sprocket)
  GetSprocket(
    reply_with: Subject(Result(Sprocket, Nil)),
    ws: WebSocket,
  )
  PopSprocket(
    reply_with: Subject(Result(Sprocket, Nil)),
    ws: WebSocket,
  )
}

Constructors

```
Shutdown
```

GetState(reply_with: Subject(Result(State, Nil)))

```
PushPreflight(preflight: Preflight)
```
```
CleanupPreflights
```

StartPreflightCleanupJob(cleanup_preflights: fn() -> Nil)

PopPreflight(
  reply_with: Subject(Result(Preflight, Nil)),
  id: String,
)

```
PushSprocket(sprocket: Sprocket)
```

GetSprocket(
  reply_with: Subject(Result(Sprocket, Nil)),
  ws: WebSocket,
)

PopSprocket(
  reply_with: Subject(Result(Sprocket, Nil)),
  ws: WebSocket,
)

Preflight

</>

pub type Preflight {
  Preflight(
    id: String,
    view: Element,
    csrf_token: String,
    created_at: Int,
  )
}

Constructors

Preflight(
  id: String,
  view: Element,
  csrf_token: String,
  created_at: Int,
)

State

</>

pub type State {
  State(
    sprockets: List(Sprocket),
    preflights: List(Preflight),
    cancel_preflight_cleanup_job: fn() -> Nil,
  )
}

Constructors

State(
  sprockets: List(Sprocket),
  preflights: List(Preflight),
  cancel_preflight_cleanup_job: fn() -> Nil,
)

Functions

live_service

</>

pub fn live_service(_req: Request(Body), ca: Subject(Message)) -> HandlerResponse

pop_preflight

</>

pub fn pop_preflight(ca: Subject(Message), id: String) -> Result(
  Preflight,
  Nil,
)

push_preflight

</>

pub fn push_preflight(ca: Subject(Message), preflight: Preflight) -> Preflight

start

</>

pub fn start() -> Subject(Message)

stop

</>

pub fn stop(ca: Subject(Message)) -> Nil