chipingress: enable StreamEvents method

pkcll · pkcll · commit 28530c79fea8 · 2025-07-12T00:40:09.000-04:00
diff --git a/pkg/chipingress/client.go b/pkg/chipingress/client.go
@@ -102,8 +102,8 @@ func (c *client) PublishBatch(ctx context.Context, in *CloudEventBatch, opts ...
 }
 
 // StreamEvents - Experimental, this API is subject to change.
-func (c *client) StreamEvents(_ context.Context, _ ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error) {
-	return nil, fmt.Errorf("not implemented: StreamEvents is experimental and not supported yet")
+func (c *client) StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error) {
+	return c.client.StreamEvents(ctx, opts...)
 }
 
 func (c *client) Close() error {

Original file line number	Diff line number	Diff line change
`@@ -102,8 +102,8 @@ func (c client) PublishBatch(ctx context.Context, in CloudEventBatch, opts ...`
`102`	`102`	`}`
`103`	`103`
`104`	`104`	`// StreamEvents - Experimental, this API is subject to change.`
`105`		`-func (c *client) StreamEvents(_ context.Context, _ ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error) {`
`106`		`- return nil, fmt.Errorf("not implemented: StreamEvents is experimental and not supported yet")`
	`105`	`+func (c *client) StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error) {`
	`106`	`+ return c.client.StreamEvents(ctx, opts...)`
`107`	`107`	`}`
`108`	`108`
`109`	`109`	`func (c *client) Close() error {`