Function TestCallStream_NodeOffline

internal/nodehub/stream_test.go:131–137

TestCallStream_NodeOffline：未注册 nodeID → ErrNodeOffline。

(t *testing.T)

// TestCallStream_NodeOffline：未注册 nodeID → ErrNodeOffline。
func TestCallStream_NodeOffline(t *testing.T) {
	hub := New(Options{PeerExtractor: mdPeerExtractor})
	_, err := hub.CallStream(context.Background(), "no-such-node", "LogsStream", nil)
	if !errors.Is(err, ErrNodeOffline) {
		t.Fatalf("want ErrNodeOffline, got %v", err)
	}
}