(ctx context.Context, session quic.Connection, sessionRPCServer pogs.SessionManager, configRPCServer pogs.ConfigurationManager, t *testing.T)
| 844 | ) |
| 845 | |
| 846 | func runRPCServer(ctx context.Context, session quic.Connection, sessionRPCServer pogs.SessionManager, configRPCServer pogs.ConfigurationManager, t *testing.T) { |
| 847 | stream, err := session.AcceptStream(ctx) |
| 848 | require.NoError(t, err) |
| 849 | |
| 850 | if stream.StreamID() == 0 { |
| 851 | // Skip the first stream, it's the control stream of the QUIC connection |
| 852 | stream, err = session.AcceptStream(ctx) |
| 853 | require.NoError(t, err) |
| 854 | } |
| 855 | ss := rpcquic.NewCloudflaredServer( |
| 856 | func(_ context.Context, _ *rpcquic.RequestServerStream) error { |
| 857 | return nil |
| 858 | }, |
| 859 | sessionRPCServer, |
| 860 | configRPCServer, |
| 861 | 10*time.Second, |
| 862 | ) |
| 863 | err = ss.Serve(ctx, stream) |
| 864 | assert.NoError(t, err) |
| 865 | } |
| 866 | |
| 867 | type mockSessionRPCServer struct { |
| 868 | sessionID uuid.UUID |
no test coverage detected