| 109 | } |
| 110 | |
| 111 | func TestRunner_Stream(t *testing.T) { |
| 112 | dir := initRepo(t) |
| 113 | r := New(2) |
| 114 | |
| 115 | var content string |
| 116 | err := r.Stream(context.Background(), dir, func(stdout io.Reader) error { |
| 117 | data, err := io.ReadAll(stdout) |
| 118 | if err != nil { |
| 119 | return err |
| 120 | } |
| 121 | content = string(data) |
| 122 | return nil |
| 123 | }, "show", "HEAD:hello.txt") |
| 124 | if err != nil { |
| 125 | t.Fatalf("Stream error: %v", err) |
| 126 | } |
| 127 | if content != "hello\n" { |
| 128 | t.Errorf("Stream content = %q, want %q", content, "hello\n") |
| 129 | } |
| 130 | } |
| 131 | |
| 132 | func TestRunner_ContextCancelled(t *testing.T) { |
| 133 | r := New(1) |