Skip to content

Commit 52a9b70

Browse files
committed
Use BulkPublishEvent in the mock
Signed-off-by: Albert Callarisa <albert@diagrid.io>
1 parent 736b20d commit 52a9b70

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

client/client_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -359,10 +359,10 @@ func (s *testDaprServer) PublishEvent(ctx context.Context, req *pb.PublishEventR
359359
return &emptypb.Empty{}, nil
360360
}
361361

362-
// BulkPublishEventAlpha1 mocks the BulkPublishEventAlpha1 API.
362+
// BulkPublishEvent mocks the BulkPublishEvent API.
363363
// It will fail to publish events that start with "fail".
364364
// It will fail the entire request if an event starts with "failall".
365-
func (s *testDaprServer) BulkPublishEventAlpha1(ctx context.Context, req *pb.BulkPublishRequest) (*pb.BulkPublishResponse, error) {
365+
func (s *testDaprServer) BulkPublishEvent(ctx context.Context, req *pb.BulkPublishRequest) (*pb.BulkPublishResponse, error) {
366366
failedEntries := make([]*pb.BulkPublishResponseFailedEntry, 0)
367367
for _, entry := range req.GetEntries() {
368368
if bytes.HasPrefix(entry.GetEvent(), []byte("failall")) {

0 commit comments

Comments
 (0)