GenericSseEndpoint.java

1 
package pl.zankowski.iextrading4j.client.sse.endpoint;
2
3 
import pl.zankowski.iextrading4j.client.sse.ISseEndpoint;
4 
import pl.zankowski.iextrading4j.client.sse.manager.SseManager;
5 
import pl.zankowski.iextrading4j.client.sse.manager.SseRequest;
6
7 
import java.util.function.Consumer;
8
9 
public class GenericSseEndpoint implements ISseEndpoint {
10
11 
    private final SseManager sseManager;
12
13 
    public GenericSseEndpoint(final SseManager sseManager) {
14 
        this.sseManager = sseManager;
15 
    }
16
17 
    @Override
18 
    public <R> void subscribe(final SseRequest<R> sseRequest, final Consumer<R> consumer) {
19 1 1. subscribe : removed call to pl/zankowski/iextrading4j/client/sse/manager/SseManager::subscribe → KILLED
 
        sseManager.subscribe(sseRequest, consumer);
20 
    }
21
22 
    @Override
23 
    public <R> void unsubscribe(final SseRequest<R> sseRequest) {
24 1 1. unsubscribe : removed call to pl/zankowski/iextrading4j/client/sse/manager/SseManager::unsubscribe → KILLED
 
        sseManager.unsubscribe(sseRequest);
25 
    }
26
27 
}

Mutations

19

1.1
Location : subscribe
Killed by : pl.zankowski.iextrading4j.client.sse.endpoint.GenericSseEndpointTest.[engine:junit-jupiter]/[class:pl.zankowski.iextrading4j.client.sse.endpoint.GenericSseEndpointTest]/[method:shouldSuccessfullySubscribe()] removed call to pl/zankowski/iextrading4j/client/sse/manager/SseManager::subscribe → KILLED
24

1.1
Location : unsubscribe
Killed by : pl.zankowski.iextrading4j.client.sse.endpoint.GenericSseEndpointTest.[engine:junit-jupiter]/[class:pl.zankowski.iextrading4j.client.sse.endpoint.GenericSseEndpointTest]/[method:shouldSuccessfullyUnsubscribe()] removed call to pl/zankowski/iextrading4j/client/sse/manager/SseManager::unsubscribe → KILLED

Active mutators

Tests examined


Report generated by PIT 1.7.1