update type

protocol/streaming/grpc/grpc_streaming_manager.go

@@ -7,7 +7,7 @@ import (
 
 var _ types.GrpcStreamingManager = (*GrpcStreamingManagerImpl)(nil)
 
-// GrpcStreamingManager is an implementation for managing gRPC streaming subscriptions.
+// GrpcStreamingManagerImpl is an implementation for managing gRPC streaming subscriptions.
 type GrpcStreamingManagerImpl struct {
 }
 
@@ -30,9 +30,9 @@ func (sm *GrpcStreamingManagerImpl) Subscribe(
 	return nil, nil
 }
 
-// SendMessages groups messages by their clob pair ids and
+// SendOrderbookUpdates groups updates by their clob pair ids and
 // sends messages to the subscribers.
-func (sm *GrpcStreamingManagerImpl) SendMessages(
-	msg *clobtypes.OffchainUpdateMessage,
+func (sm *GrpcStreamingManagerImpl) SendOrderbookUpdates(
+	updates *clobtypes.OffchainUpdates,
 ) {
 }

protocol/streaming/grpc/noop_streaming_manager.go

@@ -7,7 +7,6 @@ import (
 
 var _ types.GrpcStreamingManager = (*NoopGrpcStreamingManager)(nil)
 
-// GrpcStreamingManager is an implementation for managing gRPC streaming subscriptions.
 type NoopGrpcStreamingManager struct{}
 
 func NewNoopGrpcStreamingManager() *NoopGrpcStreamingManager {
@@ -28,9 +27,7 @@ func (sm *NoopGrpcStreamingManager) Subscribe(
 	return nil, nil
 }
 
-// SendMessages groups messages by their clob pair ids and
-// sends messages to the subscribers.
-func (sm *NoopGrpcStreamingManager) SendMessages(
-	msg *clobtypes.OffchainUpdateMessage,
+func (sm *NoopGrpcStreamingManager) SendOrderbookUpdates(
+	updates *clobtypes.OffchainUpdates,
 ) {
 }

protocol/streaming/grpc/types/manager.go

@@ -15,5 +15,5 @@ type GrpcStreamingManager interface {
 		finished chan<- bool,
 		err error,
 	)
-	SendMessages(*clobtypes.OffchainUpdateMessage)
+	SendOrderbookUpdates(*clobtypes.OffchainUpdates)
 }