File tree 1 file changed +30
-0
lines changed
src/test/java/io/reactivex/tck
1 file changed +30
-0
lines changed Original file line number Diff line number Diff line change
1
+ /**
2
+ * Copyright (c) 2016-present, RxJava Contributors.
3
+ *
4
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in
5
+ * compliance with the License. You may obtain a copy of the License at
6
+ *
7
+ * http://www.apache.org/licenses/LICENSE-2.0
8
+ *
9
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is
10
+ * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See
11
+ * the License for the specific language governing permissions and limitations under the License.
12
+ */
13
+
14
+ package io .reactivex .tck ;
15
+
16
+ import org .reactivestreams .Publisher ;
17
+ import org .testng .annotations .Test ;
18
+
19
+ import io .reactivex .Flowable ;
20
+
21
+ @ Test
22
+ public class LimitTckTest extends BaseTck <Integer > {
23
+
24
+ @ Override
25
+ public Publisher <Integer > createPublisher (long elements ) {
26
+ return
27
+ Flowable .range (0 , (int )elements * 2 ).limit (elements )
28
+ ;
29
+ }
30
+ }
You can’t perform that action at this time.
0 commit comments