contentrelay_test.go RawHistoryFolder

1package wayland
2
3import (
4	"testing"
5
6	"github.com/bnema/neferwl/internal/ports"
7)
8
9// relayContents attaches an output to s before Run and returns the contents it
10// receives, one by one. It consumes batches like an output does: apply, then
11// Return. The server must not be running yet.
12func relayContents(t *testing.T, s *Server) <-chan ports.SurfaceContent {
13	t.Helper()
14	in, ret := s.attachOutput("TEST-1")
15	out := make(chan ports.SurfaceContent, 64)
16	stop := make(chan struct{})
17	t.Cleanup(func() { close(stop) })
18	go func() {
19		for {
20			select {
21			case <-stop:
22				return
23			case b := <-in:
24				for _, c := range b.Items {
25					select {
26					case out <- c:
27					case <-stop:
28						return
29					}
30				}
31				b.Reset()
32				ret.Return(b)
33			}
34		}
35	}()
36	return out
37}