update channel type

dydxprotocol · Mar 2, 2024 · 0d40546 · 0d40546
1 parent fe41e97
commit 0d40546
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/protocol/streaming/grpc/grpc_streaming_manager.go b/protocol/streaming/grpc/grpc_streaming_manager.go
@@ -24,7 +24,7 @@ func (sm *GrpcStreamingManagerImpl) Subscribe(
 	req clobtypes.StreamOrderbookUpdatesRequest,
 	srv clobtypes.Query_StreamOrderbookUpdatesServer,
 ) (
-	finished chan<- bool,
+	finished chan bool,
 	err error,
 ) {
 	return nil, nil

diff --git a/protocol/streaming/grpc/noop_streaming_manager.go b/protocol/streaming/grpc/noop_streaming_manager.go
@@ -21,7 +21,7 @@ func (sm *NoopGrpcStreamingManager) Subscribe(
 	req clobtypes.StreamOrderbookUpdatesRequest,
 	srv clobtypes.Query_StreamOrderbookUpdatesServer,
 ) (
-	finished chan<- bool,
+	finished chan bool,
 	err error,
 ) {
 	return nil, nil

diff --git a/protocol/streaming/grpc/types/manager.go b/protocol/streaming/grpc/types/manager.go
@@ -12,7 +12,7 @@ type GrpcStreamingManager interface {
 		req clobtypes.StreamOrderbookUpdatesRequest,
 		srv clobtypes.Query_StreamOrderbookUpdatesServer,
 	) (
-		finished chan<- bool,
+		finished chan bool,
 		err error,
 	)
 	SendOrderbookUpdates(*clobtypes.OffchainUpdates)