File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed 
google-cloud-spanner/src/main/java/com/google/cloud/spanner Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -773,7 +773,9 @@ CloseableIterator<PartialResultSet> startStream(
773773              AsyncResultSet .StreamMessageListener  streamListener ) {
774774            GrpcStreamIterator  stream  =
775775                new  GrpcStreamIterator (statement , prefetchChunks , cancelQueryWhenClientIsClosed );
776-             stream .registerListener (streamListener );
776+             if  (streamListener  != null ) {
777+               stream .registerListener (streamListener );
778+             }
777779            if  (partitionToken  != null ) {
778780              request .setPartitionToken (partitionToken );
779781            }
@@ -967,7 +969,9 @@ CloseableIterator<PartialResultSet> startStream(
967969              AsyncResultSet .StreamMessageListener  streamListener ) {
968970            GrpcStreamIterator  stream  =
969971                new  GrpcStreamIterator (prefetchChunks , cancelQueryWhenClientIsClosed );
970-             stream .registerListener (streamListener );
972+             if  (streamListener  != null ) {
973+               stream .registerListener (streamListener );
974+             }
971975            TransactionSelector  selector  = null ;
972976            if  (resumeToken  != null ) {
973977              builder .setResumeToken (resumeToken );
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments