forked from ReactiveX/RxJava
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
See https://help.github.com/articles/dealing-with-line-endings#re-normalizing-a-repository Fixes ReactiveX#579
- Loading branch information
1 parent
eae31cb
commit c2cd326
Showing
30 changed files
with
4,454 additions
and
4,454 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,90 +1,90 @@ | ||
@if "%DEBUG%" == "" @echo off | ||
@rem ########################################################################## | ||
@rem | ||
@rem Gradle startup script for Windows | ||
@rem | ||
@rem ########################################################################## | ||
|
||
@rem Set local scope for the variables with windows NT shell | ||
if "%OS%"=="Windows_NT" setlocal | ||
|
||
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. | ||
set DEFAULT_JVM_OPTS= | ||
|
||
set DIRNAME=%~dp0 | ||
if "%DIRNAME%" == "" set DIRNAME=. | ||
set APP_BASE_NAME=%~n0 | ||
set APP_HOME=%DIRNAME% | ||
|
||
@rem Find java.exe | ||
if defined JAVA_HOME goto findJavaFromJavaHome | ||
|
||
set JAVA_EXE=java.exe | ||
%JAVA_EXE% -version >NUL 2>&1 | ||
if "%ERRORLEVEL%" == "0" goto init | ||
|
||
echo. | ||
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. | ||
echo. | ||
echo Please set the JAVA_HOME variable in your environment to match the | ||
echo location of your Java installation. | ||
|
||
goto fail | ||
|
||
:findJavaFromJavaHome | ||
set JAVA_HOME=%JAVA_HOME:"=% | ||
set JAVA_EXE=%JAVA_HOME%/bin/java.exe | ||
|
||
if exist "%JAVA_EXE%" goto init | ||
|
||
echo. | ||
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% | ||
echo. | ||
echo Please set the JAVA_HOME variable in your environment to match the | ||
echo location of your Java installation. | ||
|
||
goto fail | ||
|
||
:init | ||
@rem Get command-line arguments, handling Windowz variants | ||
|
||
if not "%OS%" == "Windows_NT" goto win9xME_args | ||
if "%@eval[2+2]" == "4" goto 4NT_args | ||
|
||
:win9xME_args | ||
@rem Slurp the command line arguments. | ||
set CMD_LINE_ARGS= | ||
set _SKIP=2 | ||
|
||
:win9xME_args_slurp | ||
if "x%~1" == "x" goto execute | ||
|
||
set CMD_LINE_ARGS=%* | ||
goto execute | ||
|
||
:4NT_args | ||
@rem Get arguments from the 4NT Shell from JP Software | ||
set CMD_LINE_ARGS=%$ | ||
|
||
:execute | ||
@rem Setup the command line | ||
|
||
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar | ||
|
||
@rem Execute Gradle | ||
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS% | ||
|
||
:end | ||
@rem End local scope for the variables with windows NT shell | ||
if "%ERRORLEVEL%"=="0" goto mainEnd | ||
|
||
:fail | ||
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of | ||
rem the _cmd.exe /c_ return code! | ||
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 | ||
exit /b 1 | ||
|
||
:mainEnd | ||
if "%OS%"=="Windows_NT" endlocal | ||
|
||
:omega | ||
@if "%DEBUG%" == "" @echo off | ||
@rem ########################################################################## | ||
@rem | ||
@rem Gradle startup script for Windows | ||
@rem | ||
@rem ########################################################################## | ||
|
||
@rem Set local scope for the variables with windows NT shell | ||
if "%OS%"=="Windows_NT" setlocal | ||
|
||
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. | ||
set DEFAULT_JVM_OPTS= | ||
|
||
set DIRNAME=%~dp0 | ||
if "%DIRNAME%" == "" set DIRNAME=. | ||
set APP_BASE_NAME=%~n0 | ||
set APP_HOME=%DIRNAME% | ||
|
||
@rem Find java.exe | ||
if defined JAVA_HOME goto findJavaFromJavaHome | ||
|
||
set JAVA_EXE=java.exe | ||
%JAVA_EXE% -version >NUL 2>&1 | ||
if "%ERRORLEVEL%" == "0" goto init | ||
|
||
echo. | ||
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. | ||
echo. | ||
echo Please set the JAVA_HOME variable in your environment to match the | ||
echo location of your Java installation. | ||
|
||
goto fail | ||
|
||
:findJavaFromJavaHome | ||
set JAVA_HOME=%JAVA_HOME:"=% | ||
set JAVA_EXE=%JAVA_HOME%/bin/java.exe | ||
|
||
if exist "%JAVA_EXE%" goto init | ||
|
||
echo. | ||
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% | ||
echo. | ||
echo Please set the JAVA_HOME variable in your environment to match the | ||
echo location of your Java installation. | ||
|
||
goto fail | ||
|
||
:init | ||
@rem Get command-line arguments, handling Windowz variants | ||
|
||
if not "%OS%" == "Windows_NT" goto win9xME_args | ||
if "%@eval[2+2]" == "4" goto 4NT_args | ||
|
||
:win9xME_args | ||
@rem Slurp the command line arguments. | ||
set CMD_LINE_ARGS= | ||
set _SKIP=2 | ||
|
||
:win9xME_args_slurp | ||
if "x%~1" == "x" goto execute | ||
|
||
set CMD_LINE_ARGS=%* | ||
goto execute | ||
|
||
:4NT_args | ||
@rem Get arguments from the 4NT Shell from JP Software | ||
set CMD_LINE_ARGS=%$ | ||
|
||
:execute | ||
@rem Setup the command line | ||
|
||
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar | ||
|
||
@rem Execute Gradle | ||
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS% | ||
|
||
:end | ||
@rem End local scope for the variables with windows NT shell | ||
if "%ERRORLEVEL%"=="0" goto mainEnd | ||
|
||
:fail | ||
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of | ||
rem the _cmd.exe /c_ return code! | ||
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 | ||
exit /b 1 | ||
|
||
:mainEnd | ||
if "%OS%"=="Windows_NT" endlocal | ||
|
||
:omega |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,49 +1,49 @@ | ||
/** | ||
* Copyright 2013 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 rx.Notification; | ||
import rx.util.functions.Action0; | ||
import rx.util.functions.Action1; | ||
|
||
/** | ||
* Represents an active plan. | ||
*/ | ||
public class ActivePlan1<T1> extends ActivePlan0 { | ||
private final Action1<T1> onNext; | ||
private final Action0 onCompleted; | ||
private final JoinObserver1<T1> first; | ||
public ActivePlan1(JoinObserver1<T1> first, Action1<T1> onNext, Action0 onCompleted) { | ||
this.onNext = onNext; | ||
this.onCompleted = onCompleted; | ||
this.first = first; | ||
addJoinObserver(first); | ||
} | ||
|
||
@Override | ||
public void match() { | ||
if (!first.queue().isEmpty()) { | ||
Notification<T1> n1 = first.queue().peek(); | ||
if (n1.isOnCompleted()) { | ||
onCompleted.call(); | ||
} else { | ||
dequeue(); | ||
onNext.call(n1.getValue()); | ||
} | ||
} | ||
} | ||
|
||
} | ||
/** | ||
* Copyright 2013 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 rx.Notification; | ||
import rx.util.functions.Action0; | ||
import rx.util.functions.Action1; | ||
|
||
/** | ||
* Represents an active plan. | ||
*/ | ||
public class ActivePlan1<T1> extends ActivePlan0 { | ||
private final Action1<T1> onNext; | ||
private final Action0 onCompleted; | ||
private final JoinObserver1<T1> first; | ||
public ActivePlan1(JoinObserver1<T1> first, Action1<T1> onNext, Action0 onCompleted) { | ||
this.onNext = onNext; | ||
this.onCompleted = onCompleted; | ||
this.first = first; | ||
addJoinObserver(first); | ||
} | ||
|
||
@Override | ||
public void match() { | ||
if (!first.queue().isEmpty()) { | ||
Notification<T1> n1 = first.queue().peek(); | ||
if (n1.isOnCompleted()) { | ||
onCompleted.call(); | ||
} else { | ||
dequeue(); | ||
onNext.call(n1.getValue()); | ||
} | ||
} | ||
} | ||
|
||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,54 +1,54 @@ | ||
/** | ||
* Copyright 2013 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 rx.Notification; | ||
import rx.util.functions.Action0; | ||
import rx.util.functions.Action2; | ||
|
||
/** | ||
* Represents an active plan. | ||
*/ | ||
public class ActivePlan2<T1, T2> extends ActivePlan0 { | ||
private final Action2<T1, T2> onNext; | ||
private final Action0 onCompleted; | ||
private final JoinObserver1<T1> first; | ||
private final JoinObserver1<T2> second; | ||
public ActivePlan2(JoinObserver1<T1> first, JoinObserver1<T2> second, Action2<T1, T2> onNext, Action0 onCompleted) { | ||
this.onNext = onNext; | ||
this.onCompleted = onCompleted; | ||
this.first = first; | ||
this.second = second; | ||
addJoinObserver(first); | ||
addJoinObserver(second); | ||
} | ||
|
||
@Override | ||
public void match() { | ||
if (!first.queue().isEmpty() && !second.queue().isEmpty()) { | ||
Notification<T1> n1 = first.queue().peek(); | ||
Notification<T2> n2 = second.queue().peek(); | ||
|
||
if (n1.isOnCompleted() || n2.isOnCompleted()) { | ||
onCompleted.call(); | ||
} else { | ||
dequeue(); | ||
onNext.call(n1.getValue(), n2.getValue()); | ||
} | ||
} | ||
} | ||
|
||
} | ||
/** | ||
* Copyright 2013 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 rx.Notification; | ||
import rx.util.functions.Action0; | ||
import rx.util.functions.Action2; | ||
|
||
/** | ||
* Represents an active plan. | ||
*/ | ||
public class ActivePlan2<T1, T2> extends ActivePlan0 { | ||
private final Action2<T1, T2> onNext; | ||
private final Action0 onCompleted; | ||
private final JoinObserver1<T1> first; | ||
private final JoinObserver1<T2> second; | ||
public ActivePlan2(JoinObserver1<T1> first, JoinObserver1<T2> second, Action2<T1, T2> onNext, Action0 onCompleted) { | ||
this.onNext = onNext; | ||
this.onCompleted = onCompleted; | ||
this.first = first; | ||
this.second = second; | ||
addJoinObserver(first); | ||
addJoinObserver(second); | ||
} | ||
|
||
@Override | ||
public void match() { | ||
if (!first.queue().isEmpty() && !second.queue().isEmpty()) { | ||
Notification<T1> n1 = first.queue().peek(); | ||
Notification<T2> n2 = second.queue().peek(); | ||
|
||
if (n1.isOnCompleted() || n2.isOnCompleted()) { | ||
onCompleted.call(); | ||
} else { | ||
dequeue(); | ||
onNext.call(n1.getValue(), n2.getValue()); | ||
} | ||
} | ||
} | ||
|
||
} |
Oops, something went wrong.