Skip to content

Commit e9664ad

Browse files
committed
add license header to TCK
1 parent 6b4e4bd commit e9664ad

27 files changed

+308
-11
lines changed

tck/src/main/java/org/reactivestreams/tck/IdentityProcessorVerification.java

+13-2
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Processor;
@@ -638,13 +649,13 @@ public TestSetup apply(Long subscribers) throws Throwable {
638649
expectNextElement(sub1, x);
639650

640651
if (totalRequests == 1) {
641-
totalRequests += expectRequest();
652+
totalRequests= expectRequest();
642653
}
643654
final T y = sendNextTFromUpstream();
644655
expectNextElement(sub1, y);
645656

646657
if (totalRequests == 2) {
647-
totalRequests += expectRequest();
658+
totalRequests= expectRequest();
648659
}
649660

650661
final ManualSubscriber<T> sub2 = newSubscriber();

tck/src/main/java/org/reactivestreams/tck/PublisherVerification.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;

tck/src/main/java/org/reactivestreams/tck/SubscriberBlackboxVerification.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;
@@ -521,4 +532,4 @@ public T nextT() throws InterruptedException {
521532
public void notVerified() {
522533
throw new SkipException("Not verified using this TCK.");
523534
}
524-
}
535+
}

tck/src/main/java/org/reactivestreams/tck/SubscriberWhiteboxVerification.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;

tck/src/main/java/org/reactivestreams/tck/TestEnvironment.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;

tck/src/main/java/org/reactivestreams/tck/WithHelperPublisher.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,16 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
public interface Function<In, Out> {
415
public Out apply(In in) throws Throwable;
5-
}
16+
}

tck/src/main/java/org/reactivestreams/tck/support/HelperPublisher.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
import java.util.Collections;
@@ -30,4 +41,4 @@ public HelperPublisher(final int from, final int to, final Function<Integer, T>
3041
}
3142
}, executor);
3243
}
33-
}
44+
}

tck/src/main/java/org/reactivestreams/tck/support/InfiniteHelperPublisher.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
import org.reactivestreams.example.unicast.AsyncIterablePublisher;
@@ -27,4 +38,4 @@ public InfiniteHelperPublisher(final Function<Integer, T> create, final Executor
2738
}
2839
}, executor);
2940
}
30-
}
41+
}

tck/src/main/java/org/reactivestreams/tck/support/NonFatal.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314

tck/src/main/java/org/reactivestreams/tck/support/Optional.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
import java.util.NoSuchElementException;

tck/src/main/java/org/reactivestreams/tck/support/PublisherVerificationRules.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314

tck/src/main/java/org/reactivestreams/tck/support/SubscriberBlackboxVerificationRules.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
/**
@@ -30,4 +41,4 @@ public interface SubscriberBlackboxVerificationRules {
3041
void untested_spec314_blackbox_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() throws Exception;
3142
void untested_spec315_blackbox_cancelMustNotThrowExceptionAndMustSignalOnError() throws Exception;
3243
void untested_spec316_blackbox_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() throws Exception;
33-
}
44+
}

tck/src/main/java/org/reactivestreams/tck/support/SubscriberBufferOverflowException.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
public final class SubscriberBufferOverflowException extends RuntimeException {

tck/src/main/java/org/reactivestreams/tck/support/SubscriberWhiteboxVerificationRules.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
/**
@@ -32,4 +43,4 @@ public interface SubscriberWhiteboxVerificationRules {
3243
void untested_spec314_cancelMayCauseThePublisherToShutdownIfNoOtherSubscriptionExists() throws Exception;
3344
void untested_spec315_cancelMustNotThrowExceptionAndMustSignalOnError() throws Exception;
3445
void untested_spec316_requestMustNotThrowExceptionAndMustOnErrorTheSubscriber() throws Exception;
35-
}
46+
}

tck/src/main/java/org/reactivestreams/tck/support/TestException.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck.support;
213

314
/**

tck/src/test/java/org/reactivestreams/tck/EmptyLazyPublisherTest.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.example.unicast.AsyncIterablePublisher;
@@ -39,4 +50,4 @@ public Publisher<Integer> createFailedPublisher() {
3950
public long maxElementsFromPublisher() {
4051
return 0;
4152
}
42-
}
53+
}

tck/src/test/java/org/reactivestreams/tck/IdentityProcessorVerificationDelegationTest.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.testng.annotations.Test;

tck/src/test/java/org/reactivestreams/tck/IdentityProcessorVerificationTest.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Processor;

tck/src/test/java/org/reactivestreams/tck/PublisherVerificationTest.java

+11
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;

tck/src/test/java/org/reactivestreams/tck/SingleElementPublisherTest.java

+12-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,14 @@
1+
/************************************************************************
2+
* Licensed under Public Domain (CC0) *
3+
* *
4+
* To the extent possible under law, the person who associated CC0 with *
5+
* this code has waived all copyright and related or neighboring *
6+
* rights to this code. *
7+
* *
8+
* You should have received a copy of the CC0 legalcode along with this *
9+
* work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10+
************************************************************************/
11+
112
package org.reactivestreams.tck;
213

314
import org.reactivestreams.Publisher;
@@ -39,4 +50,4 @@ public Publisher<Integer> createFailedPublisher() {
3950
public long maxElementsFromPublisher() {
4051
return 1;
4152
}
42-
}
53+
}

0 commit comments

Comments
 (0)