CRLF fix

rxjava-contrib/rxjava-joins/src/main/java/rx/joins/ActivePlanN.java

@@ -1,68 +1,68 @@
-/**
- * Copyright 2014 Netflix, Inc.
- * 
- * Licensed under the Apache License, Version 2.0 (the "License"); you may not
- * use this file except in compliance with the License. You may obtain a copy of
- * the License at
- * 
- * http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-package rx.joins;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import rx.Notification;
-import rx.functions.Action0;
-import rx.functions.ActionN;
-
-/**
- * Represents an active plan.
- */
-public final class ActivePlanN extends ActivePlan0 {
-    private final ActionN onNext;
-    private final Action0 onCompleted;
-    private final List<JoinObserver1<? extends Object>> observers;
-
-    ActivePlanN(List<JoinObserver1<? extends Object>> observers,
-            ActionN onNext,
-            Action0 onCompleted) {
-        this.onNext = onNext;
-        this.onCompleted = onCompleted;
-        this.observers = new ArrayList<JoinObserver1<? extends Object>>(observers);
-        for (JoinObserver1<? extends Object> jo : this.observers) {
-        	addJoinObserver(jo);
-        }
-    }
-
-    @Override
-    protected void match() {
-    	Object[] notifications = new Object[this.observers.size()];
-    	int j = 0;
-    	int completedCount = 0;
-        for (JoinObserver1<? extends Object> jo : this.observers) {
-        	if (jo.queue().isEmpty()) {
-        		return;
-        	}
-        	Notification<? extends Object> n = jo.queue().peek();
-        	if (n.isOnCompleted()) {
-        		completedCount++;
-        	}
-        	notifications[j] = n.getValue();
-        	j++;
-        }
-        if (completedCount == j) {
-        	onCompleted.call();
-        } else {
-        	dequeue();
-        	onNext.call(notifications);
-        }
-    }
-
-}
+/**
+ * Copyright 2014 Netflix, Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ * 
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package rx.joins;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import rx.Notification;
+import rx.functions.Action0;
+import rx.functions.ActionN;
+
+/**
+ * Represents an active plan.
+ */
+public final class ActivePlanN extends ActivePlan0 {
+    private final ActionN onNext;
+    private final Action0 onCompleted;
+    private final List<JoinObserver1<? extends Object>> observers;
+
+    ActivePlanN(List<JoinObserver1<? extends Object>> observers,
+            ActionN onNext,
+            Action0 onCompleted) {
+        this.onNext = onNext;
+        this.onCompleted = onCompleted;
+        this.observers = new ArrayList<JoinObserver1<? extends Object>>(observers);
+        for (JoinObserver1<? extends Object> jo : this.observers) {
+        	addJoinObserver(jo);
+        }
+    }
+
+    @Override
+    protected void match() {
+    	Object[] notifications = new Object[this.observers.size()];
+    	int j = 0;
+    	int completedCount = 0;
+        for (JoinObserver1<? extends Object> jo : this.observers) {
+        	if (jo.queue().isEmpty()) {
+        		return;
+        	}
+        	Notification<? extends Object> n = jo.queue().peek();
+        	if (n.isOnCompleted()) {
+        		completedCount++;
+        	}
+        	notifications[j] = n.getValue();
+        	j++;
+        }
+        if (completedCount == j) {
+        	onCompleted.call();
+        } else {
+        	dequeue();
+        	onNext.call(notifications);
+        }
+    }
+
+}