Server.resource
Owns a Java client, with one to four simultaneous facade calls. Release cancels queued and running operations before closing the client.
Source and package
- Module
- io.github.libtmux.scaladsl.cats
- Declared in
- Server
- Package
- io.github.libtmux:libtmux-scala_3
- Source
- libtmux-scala-cats/src/main/scala/io/github/libtmux/scaladsl/cats/Server.scala
- Scala method declarations Declares a method, with its name, parameter lists and return type. Language documentation resource[F[_]: Async]( config: Server
Config , maxConcurrentCalls: Int = 4 ): Resource[F, Server[F]] -
Examples#
Connect to a private tmux server. Use JDK 25, Git, and tmux 3.2a through 3.7c on Linux, with /bin/cat and /bin/sh available. In an empty directory, fetch the documented library revision:
Terminal window $ git clone https://github.com/libtmux/libtmux-java.git libtmux-source && \git -C libtmux-source checkout f56392b5d9bc7f1f9c1631842333fb90f3d82d40Save this consumer setup as settings.gradle.kts: View source
rootProject.name = "api-example"includeBuild("libtmux-source") {dependencySubstitution {substitute(module("io.github.libtmux:libtmux-scala-cats_3")).using(project(":libtmux-scala-cats"))}}Save this consumer setup as build.gradle.kts: View source
plugins {scalaapplication}repositories { mavenCentral() }dependencies {implementation("io.github.libtmux:libtmux-scala-cats_3:0.0.1-alpha.17-SNAPSHOT")implementation("org.scala-lang:scala3-library_3:3.9.0")}java { toolchain { languageVersion.set(JavaLanguageVersion.of(25)) } }application { mainClass.set(providers.gradleProperty("exampleMain")) }Save this consumer setup as gradle.properties: View source
org.gradle.jvmargs=-Xmx2g -XX:MaxMetaspaceSize=768m -Dfile.encoding=UTF-8kotlin.daemon.jvmargs=-Xmx2gorg.gradle.workers.max=2Save this launcher as run.sh. It creates and stops a private tmux server, including after program failure. A shutdown failure retains its socket directory and exits unsuccessfully. View source
#!/bin/shset -euif [ "$#" -eq 0 ]; thenprintf 'Usage: sh run.sh program [arguments...]\n' >&2exit 2fibinary=$(command -v "${TMUX_BIN:-tmux}")mkdir -p /tmp/libtmux-java-devdirectory=$(mktemp -d /tmp/libtmux-java-dev/api.XXXXXX)socket="$directory/tmux.sock"config="$directory/tmux.conf"alive() {"$binary" -S "$socket" display-message -p '#{pid}' >/dev/null 2>&1}cleanup() {status=$?trap - 0 HUP INT TERMif alive; thenif ! "$binary" -S "$socket" kill-server; thenprintf 'Cannot stop tmux; kept %s\n' "$directory" >&2exit 1fiattempts=0while alive && [ "$attempts" -lt 100 ]; dosleep 0.05attempts=$((attempts + 1))doneif alive; thenprintf 'tmux is still responding; kept %s\n' "$directory" >&2exit 1fifirm -rf "$directory" || exit 1exit "$status"}trap cleanup 0trap 'exit 1' HUP INT TERMunset TMUX TMUX_PANEprintf 'set-option -g default-shell /bin/sh\n' > "$config""$binary" -S "$socket" -f "$config" new-session -d -s work-one -n editor /bin/cat"$binary" -S "$socket" split-window -h -t '=work-one:editor' /bin/cat"$binary" -S "$socket" new-window -d -t '=work-one' -n logs /bin/cat"$binary" -S "$socket" new-session -d -s work-two -n editor /bin/cat"$@" "$binary" "$socket" "$config""$binary" -S "$socket" has-session -t '=work-one'"$binary" -S "$socket" has-session -t '=work-two'Save this complete program as src/main/scala/Connect.scala. It opens an ordinary client for the launcher's server; closing the client releases its transport. View source
package io.github.libtmux.examples.api.scalacatsimport io.github.libtmux.{ServerConfig, ServerEndpoint}import java.nio.file.Pathimport io.github.libtmux.scaladsl.cats.*import _root_.cats.effect.{ExitCode, IO, IOApp}import _root_.cats.syntax.all.*/** Connect to a private tmux server. */object Connect extends IOApp {def run(args: List[String]): IO[ExitCode] = {val program = IO {require(args.length == 3, "expected: tmux-binary socket-path config-file")ServerConfig.builder().binary(args(0)).endpoint(ServerEndpoint.socketPath(Path.of(args(1)))).configFile(Path.of(args(2))).build()}.flatMap { config =>Server.resource[IO](config).use { server =>for {alive <- server.isAlive()_ <- IO.println(s"connected=$alive")} yield ()}}program.as(ExitCode.Success).handleErrorWith { error =>IO(System.err.println("Example failed: " + error.getMessage)).as(ExitCode.Error)}}}Build the minimal consumer and run the saved program with the private fixture. An operation or cleanup error makes the command exit unsuccessfully:
Terminal window $ ./libtmux-source/gradlew --project-dir . --console=plain --quiet \installDist -PexampleMain=io.github.libtmux.examples.api.scalacats.Connect && \sh run.sh build/install/api-example/bin/api-exampleExpected output:
connected=true- Parameters
-
-
config ( Server
Config ) -
maxConcurrentCalls ( Int )
-
Discussed in Commands and control mode · Capture pane output · Ownership