---- 测试：Call 错误响应 ----
(t *testing.T)
| 222 | // ---- 测试：Call 错误响应 ---- |
| 223 | |
| 224 | func TestCall_NodeReturnsError(t *testing.T) { |
| 225 | hub := New(Options{PeerExtractor: mdPeerExtractor}) |
| 226 | env := newTestEnv(t, hub) |
| 227 | cc := env.dial(t) |
| 228 | mock := startNodeMock(t, cc, "n") |
| 229 | waitOnline(t, hub, "n") |
| 230 | |
| 231 | mock.handle("boom", func(string, []byte) (bool, []byte, string) { |
| 232 | return false, nil, "kaboom" |
| 233 | }) |
| 234 | |
| 235 | _, err := hub.Call(context.Background(), "n", "boom", nil) |
| 236 | if err == nil || !strings.Contains(err.Error(), "kaboom") { |
| 237 | t.Fatalf("expected kaboom error, got %v", err) |
| 238 | } |
| 239 | } |
| 240 | |
| 241 | // ---- 测试：ctx 超时 + cancel_id 下发 ---- |
| 242 |
nothing calls this directly
no test coverage detected