diff --git a/backtester/engine/grpcserver.go b/backtester/engine/grpcserver.go
index afc5b64c..c072a2d8 100644
--- a/backtester/engine/grpcserver.go
+++ b/backtester/engine/grpcserver.go
@@ -80,6 +80,7 @@ func StartRPCServer(server *GRPCServer) error {
 	opts := []grpc.ServerOption{
 		grpc.Creds(creds),
 		grpc.UnaryInterceptor(grpcauth.UnaryServerInterceptor(server.authenticateClient)),
+		grpc.StreamInterceptor(grpcauth.StreamServerInterceptor(server.authenticateClient)),
 	}
 	s := grpc.NewServer(opts...)
 	btrpc.RegisterBacktesterServiceServer(s, server)
diff --git a/engine/rpcserver.go b/engine/rpcserver.go
index d1a25fdf..e9c1b1f6 100644
--- a/engine/rpcserver.go
+++ b/engine/rpcserver.go
@@ -148,6 +148,7 @@ func StartRPCServer(engine *Engine) {
 	opts := []grpc.ServerOption{
 		grpc.Creds(creds),
 		grpc.UnaryInterceptor(grpcauth.UnaryServerInterceptor(s.authenticateClient)),
+		grpc.StreamInterceptor(grpcauth.StreamServerInterceptor(s.authenticateClient)),
 	}
 	server := grpc.NewServer(opts...)
 	gctrpc.RegisterGoCryptoTraderServiceServer(server, &s)