Guard against null stream set.

Author: khatchad

edu.cuny.hunter.streamrefactoring.core/src/edu/cuny/hunter/streamrefactoring/core/refactorings/ConvertToParallelStreamRefactoringProcessor.java

@@ -424,7 +424,7 @@ public Object[] getElements() {
 	}
 
 	public Collection<Entrypoint> getEntryPoints(IJavaProject javaProject) {
-		return this.projectToEntryPoints.get(javaProject);
+		return this.projectToEntryPoints == null ? Collections.emptySet() : this.projectToEntryPoints.get(javaProject);
 	}
 
 	public TimeCollector getExcludedTimeCollector() {
@@ -453,7 +453,9 @@ public int getNumberOfSkippedStreamInstances() {
 	}
 
 	public Set<Stream> getOptimizableStreams() {
-		return this.getStreamSet().parallelStream().filter(s -> !s.getStatus().hasError()).collect(Collectors.toSet());
+		Set<Stream> streamSet = this.getStreamSet();
+		return streamSet == null ? Collections.emptySet()
+				: streamSet.parallelStream().filter(s -> !s.getStatus().hasError()).collect(Collectors.toSet());
 	}
 
 	@Override

edu.cuny.hunter.streamrefactoring.eval/src/edu/cuny/hunter/streamrefactoring/eval/handlers/EvaluateConvertToParallelStreamRefactoringHandler.java

@@ -415,10 +415,12 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 					resultsPrinter.print(nToUseForStreams);
 
 					// #streams.
-					resultsPrinter.print(processor.getStreamSet().size());
+					Set<Stream> streamSet = processor.getStreamSet();
+					resultsPrinter.print(streamSet == null ? 0 : streamSet.size());
 
 					// #optimization available streams. These are the "filtered" streams.
-					Set<Stream> candidates = processor.getStreamSet().parallelStream().filter(s -> {
+					Set<Stream> candidates = streamSet == null ? Collections.emptySet()
+							: streamSet.parallelStream().filter(s -> {
 						String pluginId = FrameworkUtil.getBundle(Stream.class).getSymbolicName();
 
 						// error related to reachability.
@@ -444,7 +446,8 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 										: stream.getEnclosingType().getFullyQualifiedName());
 
 					// stream attributes.
-					for (Stream stream : processor.getStreamSet()) {
+					if (streamSet != null)
+						for (Stream stream : streamSet) {
 						streamAttributesPrinter.printRecord(javaProject.getElementName(), stream.getCreation(),
 								stream.getCreation().getStartPosition(), stream.getCreation().getLength(),
 								Util.getMethodIdentifier(stream.getEnclosingEclipseMethod()),
@@ -463,8 +466,8 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 						printStreamAttributesWithMultipleValues(stream.getPossibleExecutionModes(),
 								streamExecutionModePrinter, stream, method, javaProject);
 
-						printStreamAttributesWithMultipleValues(stream.getPossibleOrderings(), streamOrderingPrinter,
-								stream, method, javaProject);
+							printStreamAttributesWithMultipleValues(stream.getPossibleOrderings(),
+									streamOrderingPrinter, stream, method, javaProject);
 
 					}
 
@@ -523,20 +526,22 @@ public Object execute(ExecutionEvent event) throws ExecutionException {
 
 					// Refactoring type counts.
 					for (Refactoring refactoring : Refactoring.values())
-						resultsPrinter.print(processor.getStreamSet().parallelStream().map(Stream::getRefactoring)
+						resultsPrinter.print(streamSet == null ? 0
+								: streamSet.parallelStream().map(Stream::getRefactoring)
 								.filter(r -> Objects.equals(r, refactoring)).count());
 
 					// Precondition success counts.
 					for (PreconditionSuccess preconditionSuccess : PreconditionSuccess.values())
-						resultsPrinter
-								.print(processor.getStreamSet().parallelStream().map(Stream::getPassingPrecondition)
+						resultsPrinter.print(streamSet == null ? 0
+								: streamSet.parallelStream().map(Stream::getPassingPrecondition)
 										.filter(pp -> Objects.equals(pp, preconditionSuccess)).count());
 
 					// Transformation counts.
 					for (TransformationAction action : TransformationAction.values())
-						resultsPrinter.print(processor.getStreamSet().parallelStream().map(Stream::getActions)
-								.filter(Objects::nonNull).flatMap(as -> as.parallelStream())
-								.filter(a -> Objects.equals(a, action)).count());
+						resultsPrinter.print(streamSet == null ? 0
+								: streamSet.parallelStream().map(Stream::getActions).filter(Objects::nonNull)
+										.flatMap(as -> as.parallelStream()).filter(a -> Objects.equals(a, action))
+										.count());
 
 					// actually perform the refactoring if there are no fatal
 					// errors.