| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in debugCompleted()
159 ofString.onSubscribe(subscription); in sendAsync()
166 ofString.onNext(item);
173 ofString.onError(throwable);
180 ofString.onComplete();
185 return ofString.getBody();
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1));
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1));
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2));
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3));
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8);
201 response.body().subscribe(ofString);
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8);
238 response.body().subscribe(ofString);
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8);
264 return ofString.getBody();
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8);
287 response.body().subscribe(ofString);
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8);
311 responsePublisher.body().subscribe(ofString);
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| H A D | InvalidSubscriptionRequest.java | 170 … BodySubscriber<String> ofString = new BadBodySubscriber<>(BodySubscribers.ofString(UTF_8)); in testNoBody() local
173 response.body().subscribe(ofString); in testNoBody()
176 String body = ofString.getBody().toCompletableFuture().get(); in testNoBody()
208 BodySubscriber<String> ofString = in testNoBodyAsync() local
217 return ofString.getBody(); in testNoBodyAsync()
253 BodySubscriber<String> ofString = new BadBodySubscriber<>( in testAsString() local
254 BodySubscribers.ofString(UTF_8)); in testAsString()
257 response.body().subscribe(ofString); in testAsString()
287 BodySubscriber<String> ofString = in testAsStringAsync() local
293 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/net/httpclient/ |
| H A D | MappingResponseSubscriber.java | 152 private final BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); field in MappingResponseSubscriber.CRSBodySubscriber
159 ofString.onSubscribe(subscription); in onSubscribe()
166 ofString.onNext(item); in onNext()
173 ofString.onError(throwable); in onError()
180 ofString.onComplete(); in onComplete()
185 return ofString.getBody(); in getBody()
336 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
338 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f1)); in compileOnly()
340 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f2)); in compileOnly()
342 BodySubscribers.mapping(BodySubscribers.ofString(UTF_8), f3)); in compileOnly()
[all …]
|
| H A D | ResponsePublisher.java | 200 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testExceptions() local
201 response.body().subscribe(ofString); in testExceptions()
235 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBody() local
238 response.body().subscribe(ofString); in testNoBody()
257 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testNoBodyAsync() local
264 return ofString.getBody(); in testNoBodyAsync()
284 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsString() local
287 response.body().subscribe(ofString); in testAsString()
306 BodySubscriber<String> ofString = BodySubscribers.ofString(UTF_8); in testAsStringAsync() local
311 responsePublisher.body().subscribe(ofString); in testAsStringAsync()
[all …]
|
| /dports/www/ilias/ILIAS-5.4.25/tests/Filesystem/Provider/FlySystem/ |
| H A D | FlySystemFileStreamAccessTest.php | 120 $stream = Streams::ofString($fileContent);
138 $stream = Streams::ofString($fileContent);
155 $stream = Streams::ofString($fileContent);
176 $stream = Streams::ofString($fileContent);
197 $stream = Streams::ofString($fileContent);
215 $stream = Streams::ofString($fileContent);
236 $stream = Streams::ofString($fileContent);
253 $stream = Streams::ofString($fileContent);
271 $stream = Streams::ofString($fileContent);
288 $stream = Streams::ofString($fileContent);
[all …]
|
| /dports/www/ilias6/ILIAS-6.14/tests/Filesystem/Provider/FlySystem/ |
| H A D | FlySystemFileStreamAccessTest.php | 121 $stream = Streams::ofString($fileContent);
139 $stream = Streams::ofString($fileContent);
156 $stream = Streams::ofString($fileContent);
177 $stream = Streams::ofString($fileContent);
198 $stream = Streams::ofString($fileContent);
216 $stream = Streams::ofString($fileContent);
237 $stream = Streams::ofString($fileContent);
254 $stream = Streams::ofString($fileContent);
272 $stream = Streams::ofString($fileContent);
289 $stream = Streams::ofString($fileContent);
[all …]
|