GenericSocketEndpoint.java

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

Mutations

19

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

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

Active mutators

Tests examined


Report generated by PIT 1.7.1