diff --git a/client.go b/client.go index ad223040..de48e032 100644 --- a/client.go +++ b/client.go @@ -135,6 +135,8 @@ func (c *Client[Req, Res]) CallServerStream(ctx context.Context, request *Reques return nil, c.err } conn := c.newConn(ctx, StreamTypeServer) + request.spec = conn.Spec() + request.peer = conn.Peer() mergeHeaders(conn.RequestHeader(), request.header) // Send always returns an io.EOF unless the error is from the client-side. // We want the user to continue to call Receive in those cases to get the