Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -357,7 +357,7 @@ class ReactorCoreTest extends AgentTestRunner {
"basic flux" | 2 | { -> Flux.fromIterable([1, 2]).map(addOne) }
}

def "Fluxes produce the right number of results '#scheduler'"() {
def "Fluxes produce the right number of results on '#schedulerName' scheduler"() {
when:
List<String> values = Flux.fromIterable(Arrays.asList(1, 2, 3, 4))
.parallel()
Expand All @@ -371,12 +371,11 @@ class ReactorCoreTest extends AgentTestRunner {
values.size() == 4

where:
scheduler << [
Schedulers.parallel(),
Schedulers.elastic(),
Schedulers.single(),
Schedulers.immediate()
]
schedulerName | scheduler
"parallel" | Schedulers.parallel()
"elastic" | Schedulers.elastic()
"single" | Schedulers.single()
"immediate" | Schedulers.immediate()
}

@Trace(operationName = "trace-parent", resourceName = "trace-parent")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -359,7 +359,7 @@ class RxJava2Test extends AgentTestRunner {
"basic flowable" | 2 | { -> Flowable.fromIterable([1, 2]).map(addOne) }
}

def "Flowables produce the right number of results '#scheduler'"() {
def "Flowables produce the right number of results on '#schedulerName' scheduler"() {
when:
List<String> values = Flowable.fromIterable(Arrays.asList(1, 2, 3, 4))
.parallel()
Expand All @@ -373,12 +373,11 @@ class RxJava2Test extends AgentTestRunner {
values.size() == 4

where:
scheduler << [
Schedulers.newThread(),
Schedulers.computation(),
Schedulers.single(),
Schedulers.trampoline()
]
schedulerName | scheduler
"new-thread" | Schedulers.newThread()
"computation" | Schedulers.computation()
"single" | Schedulers.single()
"trampoline" | Schedulers.trampoline()
}

@Trace(operationName = "trace-parent", resourceName = "trace-parent")
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,8 @@
package datadog.remoteconfig

import cafe.cryptography.ed25519.Ed25519PrivateKey
import cafe.cryptography.ed25519.Ed25519PublicKey
import cafe.cryptography.ed25519.Ed25519Signature
import datadog.remoteconfig.ConfigurationChangesListener
import datadog.remoteconfig.ConfigurationChangesTypedListener
import datadog.remoteconfig.ConfigurationDeserializer
import datadog.remoteconfig.ConfigurationPoller
import datadog.remoteconfig.JsonCanonicalizer
import datadog.remoteconfig.Product
import datadog.remoteconfig.state.ProductListener
import datadog.trace.api.Config
import datadog.trace.test.util.DDSpecification
Expand Down Expand Up @@ -1108,7 +1104,7 @@ class ConfigurationPollerSpecification extends DDSpecification {
]
}

void 'reportable errors'() {
void 'reportable errors #errorMsg'() {
when:
poller.addListener(Product.ASM_DD,
{ throw new RuntimeException('should not be called') } as ConfigurationDeserializer,
Expand Down