rpchan provides channel-like semantics over a TCP connection using net/rpc.

go get github.com/lucafmarques/rpchan

It achieves this by providing a minimal API on the RPChan[T any] type:

• Use Send if you want to send a T, similarly to ch <- T
• Use Receive if you want to receive a T, similarly to <-ch
• Use Close if you want to close the channel, similarly to close(ch)
• Use Listen if want to iterate on the channel, similarly to for v := range ch

Those four methods are enough to mimic one-way send/receive channel-like semantics.

Be mindful that since network calls are involved, error returns are needed to allow callers to react to network errors.

It's advisable, but not mandatory, to use the same type on both the receiver and sender. This is because rpchan follows the encoding/gob guidelines for encoding types and values.

package main

import (
    "github.com/lucafmarques/rpchan"
)

func main() {
    ch := rpchan.New[int](":9091")
    err := ch.Send(20)
    // ... error handling
    err = ch.Close()
}

package main

import (
    "github.com/lucafmarques/rpchan"
)

func main() {
    ch := rpchan.New[int](":9091", 100)
    for v, err := range ch.Listen() {
        // ... error handling + use v
    }
}

export GOEXPERIMENT=rangefunc

if test -n "$FUNC"; then RUN="-run $FUNC"; fi
if test -n "$FLAG"; then FLG="-$FLAG"; fi
go test ./... $RUN $FLG

export GOEXPERIMENT=rangefunc

go test -v -coverprofile=coverage.out ./... && \
go tool cover -html coverage.out -o coverage.html
go tool cover -func=coverage.out -o=coverage.out
if [ "$OPEN" = "yes" ]; then xdg-open coverage.html; fi

git fetch --tags || true

CURR_VERSION=`git describe --abbrev=0 --tags 2>/dev/null`
SPLITS=(${CURR_VERSION//./ })
MAJOR=${SPLITS[0]//v}
MINOR=${SPLITS[1]}
PATCH=${SPLITS[2]}

case $VERSION in
    major) MAJOR=$((MAJOR+1)) && MINOR=0 && PATCH=0 ;;
    minor) MINOR=$((MINOR+1)) && PATCH=0 ;;
    patch) PATCH=$((PATCH+1)) ;;
esac 

TAG="v$MAJOR.$MINOR.$PATCH"
git tag -s $TAG -m "tag($VERSION): Release version $TAG"

If built with Go 1.22 and GOEXPERIMENT=rangefunc, the Listen method can be used on a for-range loop, working exactly like a Go channel would.

README.md inspired by sourcegraph/conc