# io.github.libtmux.scaladsl.ox.Flows

- **Module:** io.github.libtmux.scaladsl.ox
- **Package:** io.github.libtmux:libtmux-scala_3
- **Language:** Scala
- **Kind:** module
- **Source:** https://github.com/libtmux/libtmux-java/blob/f56392b5d9bc7f1f9c1631842333fb90f3d82d40/libtmux-scala-ox/src/main/scala/io/github/libtmux/scaladsl/ox/Flows.scala#L15
- **Page:** https://libtmux.org/en/scala/latest/reference/io-github-libtmux-scaladsl-ox-flows/

```
object Flows
```

An Ox `Flow` over a subscription or a live view, for a supervised scope. Ox adds no new handle type (`io.github.libtmux.scaladsl`'s opaque handles work unchanged inside a `fork`); what it needs from this project is the same single-owner discipline the direct-style `Observation` and `LiveView` already give a blocking caller, expressed as a cold `Flow` instead of an `Iterator`.

## Members

### Other members

- `liveView` (method): The current view when the flow starts, then every newer one, one per notification. Completes when the view is closed, and fails with its cause when the anchor session or server has gone.
- `subscription` (method): One `Flow` element per step: an event this subscription kept, or a gap naming what was lost. Collecting the flow takes the subscription for good, through the Java subscription's own single-reader claim, and closes it when the collection ends. A second collection is refused as it starts, before it can disturb the first. The flow fails with the control client's cause if the client ended the subscription.